蟒蛇戏剧等到比赛

问题描述

我正在使用带有烧瓶的戏剧。在dramatiq 中，我有一个将文件发送到谷歌驱动器的功能。但有一个问题。

如果我只调用了一次dramatiq 函数并自己等待结果，直到所有文件都传送到谷歌驱动器，那就没问题了。

但问题是，如果我多次调用我的dramatiq 函数而不是在dramatiq 完成时等待-它会导致dramatiq 不等待上次调用的结果并再次发送函数的情况。如何防止这种行为？如果另一个不完整，我如何指示戏剧不要调用函数？需要在另一个之前等待完整的戏剧第一次调用吗？但是异步操作

我的职能是：

@dramatiq.actor(store_results=True)
def my_actor(credentials,loan_number,id_folder):

    print('start')
    g = GoogleApi(credentials)
    directory = os.path.join(UPLOAD_FOLDER_MAIN + "/" + str(loan_number))
    for i in list_of_files:
         g.upload_file(i,id_folder)
 
    return True

我尝试将 get result 与 '''block true''' 一起使用，但它会导致阻塞 I/O。如何做到异步？

谢谢

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）