如何解决蟒蛇戏剧等到比赛
我正在使用带有烧瓶的戏剧。在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 举报，一经查实，本站将立刻删除。