芹菜配(bind=True)是dask还是dramatiq？
芹菜配(bind=True)是dramatiq。
Dramatiq是一个基于Python的可靠、高性能的分布式任务队列库，用于处理异步任务。它提供了简单而强大的任务调度和执行功能，适用于各种应用场景。
在Dramatiq中，任务函数可以使用装饰器@dramatiq.actor来声明，并且可以使用bind=True参数来绑定任务函数的第一个参数为任务实例本身。这样，在任务函数内部可以通过该参数访问任务实例的属性和方法。
芹菜配(bind=True)是指在Dramatiq中使用装饰器@dramatiq.actor(bind=True)来声明任务函数，并将任务实例绑定到任务函数的第一个参数。这样做的好处是可以在任务函数内部访问任务实例的上下文信息，例如任务ID、任务状态等。
推荐的腾讯云相关产品是腾讯云容器服务（Tencent Kubernetes Engine，TKE）。TKE是腾讯云提供的一种高度可扩展的容器管理服务，支持在云端快速部署、管理和扩展容器化应用。TKE提供了强大的容器编排和调度能力，可以方便地部署和管理Dramatiq等任务队列系统。
更多关于腾讯云容器服务的信息，请访问：腾讯云容器服务产品介绍
相关·内容
我使用芹菜已经有一段时间了，但由于缺乏windows支持，我正在寻找替代方案。 最大的竞争者似乎是dask和dramatiq。我真正在寻找的是可以将1000个长时间运行的任务分布到10台机器上的东西。每个任务都应该在完成任务后获得下一个任务，并使用更新进行回调(在芹菜中，这可以通过@ task (bind=True)很好地实现，因为任务实例本身可以被访问，我可以将状态发送回发送更新的实例)。在dramatiq或dask</em
浏览 18提问于2019-02-20得票数 0
1回答
芹菜消费者与生产者分离
、、、
我用芹菜配兔子。因此，我想知道是否有一种方法可以配置芹菜，以便在一个项目中，我有一个将消息发送到队列(生产者)的Flask应用程序。在另一个项目中，我让芹菜实例运行，它侦听消息并执行任务(使用者)。我是把API (发送电子邮件)放进我的烧瓶应用程序还是芹菜项目？最终，我希望在不同的EC2实例中使用Flask应用程序和芹菜实例--使用rabbitmq充当消息代理。
谢谢你的帮忙!
浏览 3提问于2013-10-28得票数 11
回答已采纳
我在Django用芹菜配兔子。我的任务是独立的，我使用了gevent策略。我想在多个进程上运行芹菜任务(因为gevent运行在单个进程上)。但是记忆是无缘无故地成长起来的，没有任何任务。发生了什么？这是我的芹菜命令：
celery multi start 10 -P gevent -c 500 -A my-app -l info -E --without-gossip --without-mingle--without-heartbeat --pidfile='my-path&
浏览 12提问于2022-10-16得票数 0
回答已采纳
我感兴趣的是创建一个dask.array.Array，它在compute()之前/之后打开和关闭资源。import dask.array as da _open = True
self.我可以“欺骗”一些以包含打开文件的任务，方法是在对map_blocks的调用中包含一个
浏览 7提问于2021-11-14得票数 1
回答已采纳
2回答
现在我有一些同步作业，它们是有状态的，所以如果任务失败，我必须取消确认消息，然后让它们转到RabbitMQ前面。但当我试图提出一个错误，我发现芹菜仍然承认这条信息，队列已被清除。@celery.task(bind=True) raise ValueErrordef my_task(self, *args
浏览 5提问于2020-06-12得票数 4
回答已采纳
我正在使用芹菜排队长时间运行的任务，必须执行顺序。芹菜是工作中的错误工具吗？ time.sleep(0.5)task_track_started=True
浏览 3提问于2021-05-05得票数 0
回答已采纳
1回答
'json') sender.add_periodic_task(10.0, print_text.s('text'), name='add every 10 sec')
def print_text(
浏览 2提问于2020-10-25得票数 0
我用芹菜配酒瓶，我的任务如下：def failing_task(self):
time.sleep(random.randint
浏览 0提问于2018-02-24得票数 2
回答已采纳
我目前正在使用Django DB作为后端测试Django芹菜结果。当我的Django视图调用芹菜任务时，它被正确地添加到Django DB中，该任务由芹菜工作者执行。
浏览 3提问于2017-07-02得票数 2
我对python还不熟悉，但我知道self是自动通过的，我无法理解为什么我会得到这个错误，而且我在getGraph函数中也得到了同样的错误。这里出什么问题了？
浏览 3提问于2017-09-01得票数 1
回答已采纳
我有一个简单的芹菜模块(worker.py)，看起来像：我正在使用pyinstaller编译模块然后，我可以使用以下命令轻松地使用python模块运行芹菜工作人员：我的问题<e
浏览 5提问于2021-04-09得票数 1
回答已采纳
1回答
芹菜杀灭过程
、、
我用芹菜3.1.23。任务代码非常简单： print 'test'我发出芹菜的命令：
芹菜-A任务工作人员--loglevel=info问题是芹菜会周期性地杀死工人，然
浏览 0提问于2016-09-06得票数 3
回答已采纳
Traceback (most recent call last) 2 import dask.dataframe201_1_2_3_sorted, 6 on=["docdb_family_id"] 8 #right_index=True
File ~&#x
浏览 9提问于2022-09-21得票数 0
pandas.DataFrame.copy API可以在dask.DataFrame中精确地模仿吗，使用以下代码？from copy import copy是简单的还是深的复制？我怎样才能复制另一种副本呢？第二个代码片段将完全解决我的问题，还是有一些警告？
浏览 1提问于2018-07-01得票数 1
回答已采纳
2回答
=True, default_retry_delay=5, max_retries=1, acks_late=True) print('updating university index')
我得到的唯一输出是calling celery task。芹菜终点站里什么都没有。我想可能是app.task对task装饰师，但似乎不是这样。@app.task(bind=True
浏览 1提问于2020-06-28得票数 0
回答已采纳
1回答
我试着在我现有的烧瓶项目中添加芹菜。添加之后，我在运行时得到了一个“在应用程序上下文之外工作”错误。看来芹菜工人缺乏我的应用背景。但在这种情况下，我不知道如何将应用上下文传递给芹菜工人。下面是我当前的结构(我尝试遵循带有蓝图和api文档的工厂模式)：-app -controller.pyfrom app import create_appif __name__ == '__
浏览 0提问于2019-07-04得票数 3
回答已采纳
3回答
直接测试芹菜任务
、、
这在我的代码中实现如下：def some_task(self, record_id):@app.task(bind=True) task = bar.apply_async()foo_poll.apply_async(args=[task.id])
@app.task(bind</
浏览 4提问于2017-07-10得票数 7
1回答
芹菜为什么任务要排队
、、、、
所以我用芹菜配RabbitMQ。我有一个注册用户的RESTful API。我使用远程芹菜工人异步发送注册电子邮件，以便我的API可以返回快速响应。问题是当我查看RabbitMQ管理控制台时。我可以看到，send_registration_email创建了一个随机队列。类似于：我可以看到任务已经成功地执行了。这是任务有效负载：
{"status": "SUCCESS", "traceback": null, "result": <em
浏览 2提问于2014-01-12得票数 1
回答已采纳
1回答
我在一个服务器上有一个django应用程序+ redis，在另一个服务器上有芹菜。我想调用django应用程序的芹菜任务。我在芹菜服务器上的task.py：app.conf.broker_url = 'redis://localhost:6379/0'
def test():
print
浏览 2提问于2022-09-29得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
