我想使用Daskdelayed
任务来调用一个外部程序,该程序将其进度输出到STDOUT
。在delayed
中,我计划监视STDOUT
,并希望用从STDOUT
中提取的进度信息更新正在等待delayed
任务的Client
进程。有没有推荐的delayed
任务与其Client
进程通信的方法,或者我需要自己滚动?
您可以使用dask提供的任何协调原语或参与者来实现这种流。根据您的描述,Queue或pubsub机制似乎是最受欢迎的。您应该注意,所有这些通常都是低频和低音量通信的手段。