Dramatiq:在actor函数中获取工作者名称

Question

Dramatiq是否提供了一种在@dramatiq.actor函数中获得某种人类可读的工作者名称的方法？我会用它来将日志行从不同的作品中分离出来。

例如，类似dramatiq-process-1-worker-3的内容。

@dramatiq.actor(broker=redis_broker, store_results=True, result_ttl=10*1000)
def ping():
# Log worker name here

Answer 1

• 您可以使用CurrentMessagemiddllware

from dramatiq.middleware import CurrentMessage
@dramatiq.actor(broker=redis_broker, store_results=True, result_ttl=10*1000)
def ping():
msg = CurrentMessage.get_current_message()
print(msg.actor_name)