import dramatiq
from dramatiq.brokers.redis import RedisBroker
from dramatiq.results import Results
from dramatiq.results.backends import RedisBackend
broker = RedisBroker(host="127.0.0.1", port=6379)
broker.declare_queue("default")
dramatiq.set_broker(broker)
# backend = RedisBackend()
# broker.add_middleware(Results(backend=backend))
@dramatiq.actor()
def print_words(text):
print('This is ' + text)
print_words('sync')
a = print_words.send('async')
a.get_results()我在寻找芹菜的替代品,发现了Dramatiq。我刚刚开始使用dramatiq,我无法检索结果。我甚至尝试将后端和'save_results‘设置为True。我总是收到这个AttributeError: 'Message' object has no attribute 'get_results'
有关于如何得到结果的想法吗?
发布于 2020-07-20 19:09:42
在添加结果后端时,您是在正确的轨道上。指示参与者存储结果的方法是store_results=True,而不是save_results,检索结果的方法是get_result(),而不是get_results。
https://stackoverflow.com/questions/62984937
复制相似问题