基于Das的Python异步编程

Question

有没有办法在dask中实现下面的例子？在

import time

from celery import Celery

app = Celery('celery_blog', broker='redis://localhost:6379/0', backend='redis://localhost:6379/0')


@app.task
def sl():
    time.sleep(1)


if __name__ == "__main__":
    sleeper = sl.delay()
    print('submitted')
    print(f"sleeper done: {sleeper.ready()}")
    time.sleep(2)
    print(f"sleeper done: {sleeper.ready()}")

看一下http://distributed.dask.org/en/latest/asynchronous.html在我看来，所有的例子都需要await后台任务才能开始，但是，等待块。另一方面，在用例中，它表示可以用它来代替非阻塞行为的Celery。我能找到的示例中没有一个显示了类似Celery片段的内容。我想我错过了一个关键的拼图。所以，如果你能告诉我如何做到这一点，或给我指出一个有用的链接，我将不胜感激。在

谢谢

Answer 1

正如@mdurant在评论中所说，您可能正在寻找Dask的未来接口。见https://docs.dask.org/en/latest/futures.html

from dask.distributed import Client
client = Client()

future = client.submit(function, *args, **kwargs)
future.result()  # block then get result