问题标签 [dramatiq]

按照本教程https://github.com/Bogdanp/dramatiq我创建了一个简单的 python 脚本来检查它是否有效。我做了一些简单的操作如下

它确实工作得很好。

请注意，有两个终端，一个用于运行脚本，一个用于工作人员，在下面给出的脚本中，count_word 函数中的打印语句在第二个终端中执行

所以我继续尝试在我的烧瓶应用程序中做同样的事情，我希望 process_data 中的打印语句将在工作终端中打印，但它根本没有打印，只有“嗨，我在工作”被打印我运行烧瓶应用程序的终端

我想在后台运行 process_data 函数，我是初学者并且不太了解，是否可以按照我的方式实现它？

所以我想知道如何在烧瓶的后台运行特定功能？

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

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

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

我的职能是：

我尝试使用 '''block true''' 获取结果，但它会导致块 I/O。如何做到异步？

谢谢

我有一个实例方法，我想作为演员/工人同时运行。跑步时process_request.send(service, url)，我得到TypeError: Object of type 'Foo' is not JSON serializable

services.py

tasks.py

main.py

I'm new to dramatiq an experimenting for a couple of days and I'm not getting a worker to work within a (simple) script.

test.py

result (Redis):

But when starting a dramatiq deamon from the folder with test.py:

the result is what I expected

result (Redis)

It seems that the worker is not receiving the message in this way. It's hard to find examples on the internet setting up a worker from within a script.

Is there some one who can help my getting this work?

我想要一个可以同时消费任意数量消息的戏剧演员。这些方面的东西：

我正在尝试重写Worker类以使用具有自_ConsumerThread定义run和handle_messages方法的自定义的想法来改变它们以处理同一参与者的多达 N 条预取消息。相关的变化将在这些线路和这些线路上。

虽然希望这种方法可能会奏效，但它非常hackish，并且还需要在cli上进行更改，可能还需要在actor装饰器上进行更改。

有没有更优雅的方式通过中间件或其他方法来做到这一点？

我在跑步：

• 视窗 10
• 姜戈 4+
• Python 3.9.x
• 最新版本的戏剧
• 最新版本的 Dramatiq_abort
• 最新版本的 django_dramatiq

设置.py

我正确配置了 django_dramatiq，因此正确配置了 Dramatiq。

问题是如何配置 Dramatiq_abort 和 django_dramatiq？

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

例如，类似dramatiq-process-1-worker-3.

如何从 actor 方法中访问消息 ID？我想查看正在处理哪个 id 以用于记录目的

我正在尝试将 FastApi（uvicorn 或 hypercorn）与 Redis 和 Dramatiq 一起部署为 Windows 服务器生产中的后台任务工作者。

1. Windows 中的 Dramatiq 制作有多好。
2. Huey 和 Dramatiq 是最好的，最适合在 Windows 中制作。
3. uvicorn 或 hypercorn，这是在 Windows 中运行 FastApi 最适合和稳定的生产服务器。请说明几个原因。
4. 是否有任何可用于生产的仪表板或 UI 来监控 Dramatiq 生产。