从重复函数调用到 python 生成器的管道输出

如何解决从重复函数调用到 python 生成器的管道输出

我想不出更好的标题来描述这个问题，但就在这里。

我有一个函数，它被一个接收数据的模块以随机的非预定时间间隔调用。

还有一个模块利用 websockets 并通过以下方法接收数据

def ws_handler(ws):
    for data in data_Feed():
        ws.send(json.dumps(data)) 

并且 data_Feed 会定期产生输出。

我无法找到一种方法来将虚拟 data_Feed() 替换为来自第一个模块的提要，而无需托管具有额外 websocket 的本地服务器或使用多线程。我觉得线程不应该是必要的，因为该过程是线性的，并且尝试使用 asyncio 管道都会增加延迟，而且我无法找到立即执行异步任务的方法。