问题标签 [dramatiq]

使用dramatiq 1.9.0( flask-dramatiq 0.6.0) 时，我无法调用on_success- 或 -on_failure回调。官方的Dramatiq-documentation状态回调可以这样使用：

但是，我收到以下错误：

.../site-packages/dramatiq/actor.py里面有

这表明回调不是来自类型Actor，而是来自 flask-dramatiqs LazyActor。

如果我导入原始包import dramatiq as _dramatiq并将装饰器更改为_dramatiq.actor，则什么也不会发生。任务不会开始。

如何在 中定义回调flask-dramatiq？

我有下一个结构的项目：

应用程序.py

源代码

__ check_health.py

__ health_checker.py

venv

健康检查器.py

check_health.py

应用程序.py

当我尝试开始戏剧时

戏剧引发错误：

我做错了什么？

我将 Django-Dramatiq 与 Dramatiq 和 RabbitMQ 一起使用。我一切正常，但我不确定部署到 Windows Server 的正确方法。如果服务器重新启动，我如何确保工作人员重新启动？如果我部署新的代码更改，停止并再次启动工作人员以获取更改的最佳方法是什么？

我正在尝试运行后台任务处理，redis 和 rabbitMQ 在单独的 docker 容器中工作

兔子MQ：

{"queue_name":"default","actor_name":"count_words","args":["https://github.com/Bogdanp/dramatiq"],"kwargs":{},"options":{} "message_id":"8e10b6ef-dfef-47dc-9f28-c6e07493efe4","message_timestamp":1608877514655}

雷迪斯

错误：

我正在尝试使用 Dramatiq 和 RabbitMQ 部署网络服务器，但似乎 RabbitMQ 无法在 Cloud Run 中启动。

我看到的错误消息是：

未捕获信号：10，pid=418，tid=418，fault_addr=0。

和许多实例：

容器沙箱：不支持的系统调用 getsockopt(0x44,0x1,0xc,0x3e18e39fc540,0x3e18e39fc548,0x0)。

我用了4GB的内存，所以我觉得应该够用了。同样重要的是：容器确实在本地运行。有任何想法吗？

我是新手，dramatiq我没有找到如何dramatiq像芹菜一样以分离模式开始的方法？

我尝试从标志--d --detach 开始，但没有任何效果。

请告诉我如何在我开始时以分离模式开始戏剧性dramatiq app:broker

我已经启动了一个 Dramatiq 工作人员来完成一些任务，过了一段时间，它就卡住了，并在一段时间后抛出了下面提到的错误。

[MainThread] [dramatiq.MainProcess] [CRITICAL] PID 53 的 Worker 意外退出（代码 -9）。关机...

发生这种情况的潜在原因是什么？系统资源是一种约束吗？

此排队任务在 Kubernetes pod 中运行

我正在尝试运行 django-dramatiq --watch，但它返回一个 RuntimeError：win32 不支持监视源更改。

django-dramatiq 版本：

戏剧版：

我的 Python 安装和我的系统都是 64 位的，所以我不明白这个问题

我正在测试 Dramatiq 来代替芹菜，到目前为止我非常喜欢这种体验。我在 gitlab 上的 CI/CD 过程中比我应该更努力，特别是我似乎无法在后台产生 Dramatiq 工作人员。这导致 gitlab 管道无法完成。我们目前没有使用 docker 来部署我们的应用程序。

这是我最近（失败）在后台生成 dramtiq 工作人员的尝试：

我目前docker-compose在一个 8 核实例（docker_serivce、dramatiq_service、rabbitmq_service、postgres_service 等）上运行： django_apscheduler==0.5.2 dramatiq [rabbitmq, watch]==1.8.1 RabbitMQ (rabbitmq: 3.8-management-alpine image)

错误是许多进程正在执行相同的任务。任务只创建一次（apscheduler BackgroundScheduler），但有几个进程尝试执行它，并且不同进程之间的一些线程是相同的。

这是一个例子。该作业在队列中一次，但是当它执行时，许多进程都会接受它。139698903181056是线程，21是进程