回答情况：
提问时间：
问题标签：
import dramatiqfrom dramatiq.results import Resultsdramatiq.set_broker(broker)# broker.add_middleware(Results(backend=backend))
def p
浏览 10修改于2020-07-20得票数 0
我是dramatiq的新手，我不知道如何像芹菜一样在分离模式下启动dramatiq？ 我试着从标志开始--d --分离，但是什么都不起作用。请告诉我当我启动dramatiq app:broker时如何在分离模式下启动戏剧性
浏览 17修改于2021-04-17得票数 0
我已经启动了一个剧作家来做一些工作，在一个点之后，它只是卡住了，在一段时间后抛出了下面提到的错误。发生这种情况的潜在原因是什么？系统资源是一种约束吗？
浏览 9提问于2021-05-02得票数 1
Dramatiq提供了一种在@dramatiq.actor函数中获取工作人员某种人类可读的名称的方法吗？我会用它来区分日志行和不同的作品。例如，类似于dramatiq-process-1-worker-3。@dramatiq.actor(broker=redis_broker, store_results=True, result_ttl=10*1000) # Log worker
浏览 4提问于2021-11-26得票数 0
回答已采纳
我试图使用django-dramatiq来运行一个由几个阶段组成的管道，每个阶段定义为dramatiq Actor，使用pipeline(<stages>).run()方法，但它只是运行第一个阶段/Actor我定义了一些假演员来说明这个问题：def fake_extract(process_pk, *args, **kwargs):print(f"fake_extract: Process PK= {process_pk}
浏览 39提问于2022-08-24得票数 0
我的演员长得像这样：def process_vk_page(link: str):经纪人在哪里
broker = RabbitmqBrokerDramatiq版本为1.7.0。
浏览 2修改于2020-01-05得票数 7
我正在尝试做一个分布式任务队列Django项目，使用Dramatiq作为worker库。CONFIGDRAMATIQ_BROKER = {(DRAMATIQ_REDIS_URL), "MIDDLEWARE": [
"dramatiq</
浏览 3修改于2019-07-31得票数 2
回答已采纳
最大的竞争者似乎是dask和dramatiq。我真正在寻找的是可以将1000个长时间运行的任务分布到10台机器上的东西。在dramatiq或dask中有没有类似的功能？如有任何建议，我们将不胜感激。
浏览 18修改于2019-08-26得票数 0
我目前在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)
错误在于许多进程都在执行相同的任务
浏览 62提问于2021-06-11得票数 1
我使用Django-Dramatiq与Dramatiq和RabbitMQ。我已经完成了所有的工作，但我不确定部署到Windows的正确方法。如果服务器重新启动，如何确保工作人员再次启动？
浏览 1提问于2020-12-15得票数 2
test.pyfrom dramatiq.brokers.redis import RedisBrokerfrom dramatiq.results import Results结果(Redis)：
127.0.0.1:637
浏览 6提问于2021-08-18得票数 2
我尝试自己编写包装@dramatiq.actor装饰器的装饰器，以便向适用于所有任务的@dramatiq.actor装饰器中添加一个默认参数(我正在讨论的参数是priority=100)。由于某些原因，我得到了以下错误：如果我将我的自定义@task装饰器换成@dramatiq.actordecorators.py def decora
浏览 9提问于2020-01-07得票数 2
回答已采纳
poetry run dramatiqpoetry run dramatiqsetsid nohup poetry run dramatiq但是，像poetry run dramatiq api:broker worker.tasks --processes 1一样，直接运行剧情片会导致剧情片在后台运行。
浏览 10修改于2022-04-15得票数 0
(当我说动态时，我指的是所描述的)
例如，Dramatiq或任何其他调度器会允许像动态用户启动的周期性任务调度那样进行定制吗？
浏览 3提问于2021-06-16得票数 1
我正在尝试使用dramatiq和RabbitMQ部署一个Run服务器，而RabbitMQ似乎无法在云运行中启动。
浏览 2提问于2021-03-28得票数 0
回答已采纳
例如，我有一个Django自定义管理命令，它定期(APScheduler + CronTrigger)向Dramatiq发送任务。crontab
"""Adds cron job which triggers Dramatiqadd_cron_job(self, scheduler: BaseScheduler, actor, crontab):
"""
浏览 2提问于2021-02-19得票数 0
但是做异步的@dramatiq.actor(store_results=True)
def my_actor(credentials, loan_number, id_folder):
浏览 7提问于2021-06-22得票数 1
我让uwsgi启动了9个django应用程序的实例，以及websockets的gunicorn，以及用于队列处理的dramatiq。在重新启动的前17分钟，它似乎是疯狂的交换。
浏览 0修改于2023-03-10得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号