我最近把我的芹菜安装升级到了4.0。经过几天的努力升级,我终于开始工作了.说大也大吧。有些任务将返回,但最终任务不会返回。
我有一个类SFF,它接收并解析一个文件:
# Constructor with I/O file
def __init__(self, file):
# File data that's gonna get used a lot
sffDescriptor = file.fileno()
fileName = abspath(file.name)
# Get the pointer to the file
filePtr
我在我的django项目中用芹菜和红葡萄酒。我正在尝试用从我的celery_app延迟10秒的时间调用with函数。每当函数执行时,页面只会说localhost没有响应。我想是因为我的后端不工作吧?有人能帮忙吗?如果我删除带有结果的2行,get方法就能工作。
celery_app.py
from __future__ import absolute_import
import os
from celery import Celery
from django.conf import settings
from celery.schedules import crontab
# set the
我有一个很大的csv文件,我将其拆分成一个100000行的块列表,将每个块传递给一个函数进行复杂的计算,并将结果附加到一个global_list中。当最后一个块完成时,我使用global_list并对其进行一些统计。在global_list上执行函数complex_calc之前,我如何让celery并行处理所有块,而不是等到最后一个任务/最后一个块完成?
谢谢你的帮助
for chunk in global_chunk_list:
def func_calc.delay(chunk) #<<<<< use celery tasks
complex_calc
试图了解芹菜如何与来自的狂犬病to起作用
代码:
from celery import Celery
app=Celery('tasks',backend='amqp',broker='amqp://')
@app.task(ignore_result=True)
def print_hello():
print 'hello'
for i in xrange(2,222222):
print i
print_hello()
问题:
运行celery worker -A celery_te
我试图使用芹菜定期查询外部api,并使用新数据更新Django项目中的数据库。芹菜正确地安排任务并发送给芹菜工人,但是它从不执行任何事情。
下面是我的celery.py文件,它与我的settings.py处于相同的级别:
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from django.conf import settings
from celery.schedules import crontab
os.environ.setdefault(
我正在使用一些任务来做一些操作,同时我向用户显示额外的‘等待表单’,然后当任务的功能完成时,欢迎表单从任务中关闭。我已经有了解决方案,并在这个主题中进行了讨论:
现在的问题是,我想在其他地方实现它,而我面临的问题是我的等待表单仍然在原地(没有关闭),我不知道为什么。我可以说的是,我检查了函数是否正在取值--这是肯定的。我想这是因为函数在欢迎窗体出现之前就完成了,所以它堆叠了……有没有办法检查一下是不是这样?这就是代码:
Dim pic As New Waiting
Dim tsk As Task(Of Boolean) = Task.Factory.Star
考虑一下守则:
from celery import Celery, group
from time import time
app = Celery('tasks', broker='redis:///0', backend='redis:///1', task_ignore_result=False)
@app.task
def test_task(i):
print('hi')
return i
x = test_task.delay(3)
print(x.get())
我通过调用python scri