OSCで受け取る値を元にある関数(loop)を1秒あたり30回実行したい

Question

やりたいこと

OSCで受け取る値を元にある関数(loop)を1秒あたり30回実行したい

用いるライブラリ

• python-osc
• asyncio

困っていること

python-oscのライブラリのexampleに以下のようなOSCで非同期ioを行うコードがありました

osc-sample.py

from pythonosc.osc_server import AsyncIOOSCUDPServer
from pythonosc.dispatcher import Dispatcher
import asyncio


def filter_handler(address, *args):
    print(f"{address}: {args}")


dispatcher = Dispatcher()
dispatcher.map("/filter", filter_handler)

ip = "127.0.0.1"
port = 1337


async def loop():
    """Example main loop that only runs for 10 iterations before finishing"""
    for i in range(10):
        print(f"Loop {i}")
        await asyncio.sleep(1)


async def init_main():
    server = AsyncIOOSCUDPServer((ip, port), dispatcher, asyncio.get_event_loop())
    transport, protocol = await server.create_serve_endpoint()  # Create datagram endpoint and start serving

    await loop()  # Enter main loop of program

    transport.close()  # Clean up serve endpoint


asyncio.run(init_main())

このコードのloopの部分をできるだけ正確に30回/秒で実行したいと考えました。
そこで取り敢えず30FPSで正確に動くサンプルコードを書いて見ました

signal_sample.py

import signal
import time

FPS = 30

period = 1/FPS

def scheduler(arg1, args2):
    print(time.time())

signal.signal(signal.SIGALRM, scheduler)
signal.setitimer(signal.ITIMER_REAL, 1, period)

time.sleep(30)#30秒schedulerを実行する

この二つを合わせてosc_sample.pyのloopの部分をsignal_sample.pyの30FPSで動くようにしたら良いと考えました。

そこで書いたのが以下のコードです

signal_osc.py

from pythonosc.osc_server import AsyncIOOSCUDPServer
from pythonosc.dispatcher import Dispatcher
import asyncio
import signal
import time

FPS = 30
period=1/FPS

def fil_test(address, arg):
    print(f"{address}: {arg}")

dispatcher = Dispatcher()
dispatcher.map("/filter", fil_test)

ip="0.0.0.0"
port = 9000

async def scheduler(arg1,arg2):
   await loop()

async def loop():
   """Example main loop that only runs for 10 iterations before finishing"""
   print("loop   now time: "+str(time.time()))


async def init_main():
   print("init_main")
   server = AsyncIOOSCUDPServer((ip, port), dispatcher, asyncio.get_event_loop())
   transport, protocol = await server.create_serve_endpoint()  # Create datagram endpoint and start serving

   # Enter main loop of program
   signal.signal(signal.SIGALRM, scheduler)
   signal.setitimer(signal.ITIMER_REAL, 1, period)
   time.sleep(1000)

   transport.close()  # Clean up serve endpoint


asyncio.run(init_main())

すると以下のようなエラーが帰ってきました

init_main
signal_osc.py:35: RuntimeWarning: coroutine 'scheduler' was never awaited
  time.sleep(1000)
RuntimeWarning: Enable tracemalloc to get the object allocation traceback

非同期I/Oあたりの勉強不足だとは思うのですが、次に何をするべきなのか(考えるべきなのか)ご教授いただけると幸いです。
どうぞよろしくお願いいたします。

環境

Raspberry pi 3 B+
Python3.7

Comments

[coco_bauer]

「30FPSで実行する」というのは、どういう意味ですか？ 　動画のフレームレートの単位であるFPS(Frame per second)というのは知っていますが、質問でつかわれている"FPS"が何なのか判りません。

[kazamaru]

ありがとうございます。
1秒あたりにloop関数を呼び出す回数のことです
普段映像を作っているのでメインとなるループをframeとして数えるものだと勝手にその様に読んでしまいました。ご指摘ありがとうございます。

Answer 1

非同期I/Oあたりの勉強不足だとは思うのですが、次に何をするべきなのか(考えるべきなのか)ご教授いただけると幸いです。

????の返答ではないですが、単にエラーを直したいのであれば、 def scheduler() と def scheduler(arg1, args2) の定義が重複しているので、 rename 等すればよいかと思います。

async def scheduler(arg1, args2): # 引数を追加
   await loop()

signal に渡す関数は2つの引数を取ることを期待しているので、引数を追加すれば良いと思いました。

非同期I/Oあたりの勉強不足

もしエラーを直したいだけであったとしたら、これも特に関係と思いますので、エラー文をしっかり読むことと、エラー文で理解できない部分を検索なりで解決する練習をするべきではないでしょうか。

Comments

[kazamaru]

ありがとうございます
> def scheduler() と def scheduler(arg1, args2) の定義が重複している
scheduler()の定義は一回しかしていないと思うのですがこれはどのような意味でしょうか...
加えての質問、失礼ながらよろしくお願いします。

[unhappychoice]

失礼しました、修正しましたmm

[kazamaru]

signal.signal(signal.SIGALRM, scheduler)でschedulerに二つの値が渡るのでdef scheduler(arg1, args2)とするべきということと理解しました。ありがとうございます