芹菜/Redis同一任务被多次并行执行
我有两个自定义任务(TaskA和TaskB)，它们都继承自celery.Task。调度程序时不时地启动TaskA，而TaskA每次启动N次TaskB使用不同的参数。但由于某些原因，有时使用相同参数的相同TaskB会同时执行两次，这会导致数据库出现不同的问题。 class TaskA(celery.Task): def run(self, *args, **kwargs):
..
django相关内容
芹菜，叫延时倒计时
我正在尝试了解芹菜是如何工作的 在tasks.py文件中的Django应用程序中，我创建了一个任务： @celery.shared_task(default_retry_delay=2 * 60, max_retries=2) def my_task(param1, param2): # There are some operations 我使用以下代码调用此任务：
..
芹菜：启动时启动任务
我有一个任务需要在芹菜启动时启动。此任务下一次通过回调/ETA每5分钟运行一次。 我找到了一些关于它的线索，但在芹菜3上似乎没有奏效的线索。 感谢您的帮助， 阿诺德。 推荐答案 芹菜irc频道的某个人通过使用"；worker_ready.connect"；信号：http://docs.celeryproject.org/en/latest/userguide
..
kombu.exceptions.EncodeError：用户不可JSON序列化
我有Django 1.11.5应用和芹菜4.1.0，我一直收到： kombu.exceptions.EncodeError: is not JSON serializable 我的settings.py： CELERY_BROKER_URL = 'amqp://localhost' CELERY_RESULT_BACKEND = 'amqp://l
..
为什么我的程序在urllib3日志启动新的HTTPS连接后挂起？
我正在尝试诊断一个问题，其中我的一些芹菜工作进程似乎挂起了几分钟。我有许多任务需要进行几个IO调用(通常是对第三方API)。在任何给定的工作中，我可能会向各种API发出数千个请求。我看过这些日志，它们没有什么共同之处：它们在urllib3连接到远程url后挂起。 在我的作业结束时(大约需要30分钟)，通常有几个任务处于挂起状态。 以下是我用来得出urllib3是罪魁祸首的日志示例：
..
如何跟踪形成芹菜和弦首部的组内单个任务的进度？
import celery def temptask(n): header=list(tempsubtask.si(i) for i in range(n)) callback=templink.si('printed at last?') r = celery.chord(celery.group(header))(callback) return r @tas
..
芹菜单元测试重试
我当前正在为我的芹菜任务编写单元测试，希望测试我的任务是否正在重试。 注意：在测试设置中，ALWAYS_EAGER设置为True @app.shared_task(bind=True, soft_time_limit=600, autoretry_for=(Exception,), retry_kwargs={'max_retries': 3}, re
..
如何在姜戈测试芹菜周期任务？
我有一个简单的定期任务： from celery.decorators import periodic_task from celery.task.schedules import crontab from .models import Subscription @periodic_task(run_every=crontab(minute=0, hour=0)) def deactiva
..
在Django中调用.Delay()后，芹菜任务挂起
从Django应用程序调用导入任务的.delay()方法时，进程停滞，请求从未完成。 我们在控制台上也没有收到任何错误。 使用PDB设置set_trace()会产生相同的结果。 检查了以下无助于解决问题的问题： Calling celery task hangs for delay and apply_async celery .delay hangs (recent, n
..
使用参数(django/python-Social-auth)将Google OAuth访问限制为一个域
我正在为我的公司构建一个内部WebApp以供使用，并希望使用我们的Google Apps域来管理来自我们公司域名用户名(此问题的睡觉为example.com)的访问。 我正在使用： Django==1.9.5 python-social-auth==0.2.19 + dependencies 通过阅读其他SO问题，我发现可以通过以下设置使用GOOG“托管域”(HD)参数：
..
Django get()返回了多个
我有此错误，如何修复此错误？ get()返回多个事件--它返回%2！ 你们能帮助我理解这是什么意思吗？或许可以提前告诉我以后如何避免此错误？ 模型 class Event (models.Model): name = models.CharField(max_length=100) date = models.DateField(default='')
..
使用Django ORM可以通过多少种方式获取ManyToMany字段数据
假设我有一个名为A和B的模型。在模型B中，我有ManyToMany字段要建模A，那么我可以通过多少种方式使用模型B 从模型A获取数据 class A(models.Model): name= models.CharField(...) class B(models.Model): a= models.ManyToManyField(A) 推荐答案 最直接的两种方式是
..
姜戈过滤多对多包含
我正在尝试通过多对多关系对一堆对象进行过滤操作。因为trigger_roles字段可能包含多个条目，所以我尝试了contains过滤。但是，由于这是设计用于字符串的，我几乎无能为力，我不知道应该如何过滤这个关系(您可以忽略values_list()ATM机。)。 此函数附加到用户配置文件： def getVisiblePackages(self): visiblePackage
..
为ManyToMany字段批量创建的正确方式，Django？
我有用于填充表的代码。 def add_tags(count): print "Add tags" insert_list = [] photo_pk_lower_bound = Photo.objects.all().order_by("id")[0].pk photo_pk_upper_bound = Photo.objects.all().order_b
..
如何在JJUA中循环使用多个值的字典？
我有一个字典，如下所示：{'a': [Object, 0], 'b': [Object, 1] }其中object是具有多个属性的实际对象。我正在尝试检查每个键，看看数组中的第二个值是0还是1。如果是1，我将显示“Hello”，如果是0，则显示“GOODBAY”。以下是到目前为止似乎不起作用的内容： {% for key in follower_list %} {% if follow
..
Django反向外键约束
我有两个型号：资产和贸易。交易模型具有通过外键链接的资产，该外键允许空值，具体取决于交易的状态。资产始终需要通过外键链接到交易。一个资产可以有多个交易，但一个交易只能有一个资产。问题是，有时资产是在没有交易的情况下创建的，这需要失败，因为它会导致更多错误，因为这是不可能的。如何确保资产模型的反向外键永远不为NULL，而将ON_DELETE参数保持为SET_NULL？ class Trade(
..
如果我担心代码安全，我应该只在服务器上部署.pyc文件吗？
我想将Django应用部署到云计算环境，但我担心源代码安全。我可以只在那里部署编译的.pyc文件吗？根据官方的python文档，PYC文件“相当难进行反向工程”。 采用这种方法的利弊是什么？这是标准做法吗？ 我没有使用AWS，我只能说我所在的国家完全不能信任云计算. 推荐答案 部署.pyc文件并不总是有效。例如，如果使用Apache/mod_wsgi，至少WSGI脚本文件仍
..
如何在弹性豆茎上使用Django提供Reaction应用程序？
我过去在Heroku上有我的应用程序，它在那里的工作方式是我有2个构建包。一个用于NodeJS，一个用于Python。Heroku运行npm run build，然后Django提供build文件夹中的文件。 每当我的GitHub存储库有新的推送时，我都会使用AWS上的代码管道来部署我的应用程序的新版本。 因为我不知道如何在EB的python环境中运行npm run build，所以我
..
使用具有弹性豆茎的数据库
我一直在尝试在AWS上部署基于Django的调查问卷应用程序。就这一点而言，我对AWS和Web应用程序完全陌生。 当我构建应用程序时，它在本地服务器上运行良好，我在settings.py： 中使用了以下代码 DATABASES = { 'default': { 'ENGINE': 'django.db.backends.sqlite3', 'NAME': os.path.jo
..
使用MSI-Django的Azure SQL Server连接
我已使用pyodbc中的AccessToken成功连接Azure SQL Server。这里我没有使用username或password来连接数据库。相反，我使用attrs_before作为passtoken。我在这里自动生成令牌。 令牌生成： identity_endpoint = os.environ["IDENTITY_ENDPOINT"] identity_header = o
..