如何安排每月1日运行的Celery任务？
Celery是一个基于Python的分布式任务队列，用于处理异步任务。要安排每月1日运行的Celery任务，可以按照以下步骤进行：
- 创建Celery任务：首先，你需要创建一个Celery任务，这个任务可以是一个函数或者一个类的方法。该任务将在每月1日运行。
- 设置定时器：为了安排任务在每月1日运行，你可以使用Python的定时器库，例如
schedule或APScheduler。在定时器中，你可以设置任务的执行时间为每月1日。 - 配置Celery调度器：Celery提供了一个调度器（Scheduler）来安排任务的执行。你可以使用Celery的调度器来设置任务的执行时间为每月1日。具体的配置方法可以参考Celery官方文档。
- 启动Celery Worker：在运行Celery任务之前，你需要启动Celery Worker来处理任务队列中的任务。你可以使用Celery提供的命令行工具来启动Worker。
- 运行任务：一旦Celery Worker启动，它将开始监听任务队列。当到达每月1日时，定时器将触发任务的执行，并将任务添加到Celery队列中。Celery Worker将从队列中获取任务并执行。
总结起来，安排每月1日运行的Celery任务的步骤包括创建Celery任务、设置定时器、配置Celery调度器、启动Celery Worker和运行任务。通过这些步骤，你可以实现每月1日运行的Celery任务。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云容器服务（Tencent Kubernetes Engine，TKE）：https://cloud.tencent.com/product/tke
- 腾讯云函数计算（Serverless Cloud Function，SCF）：https://cloud.tencent.com/product/scf
- 腾讯云消息队列（Tencent Cloud Message Queue，CMQ）：https://cloud.tencent.com/product/cmq
- 腾讯云定时任务（Tencent Cloud Timer Trigger，TimerTrigger）：https://cloud.tencent.com/product/timer-trigger
相关·内容
1回答
我使用节点-芹菜来实现芹菜和狂犬病。
就像芹菜一样，我们定义任务，然后推动它们。
我在tasks.py中定义的任务如下：
import os
import logging
from celery import Celery
import requests
backend = os.getenv('CELERY_BACKEND_URL', 'amqp')
celery = Celery('tasks', backend=backend)
celery.conf.update(
CELERY_RESULT_SERIALIZER='
浏览 5提问于2017-03-16得票数 1
我使用芹菜，它适用于异步，但我需要设置一个特定日期时间的操作。
例如“2019年8月30日，11:35，做这件事。”
我的celery.py现在非常简单，但它能工作：
import time
from datetime import datetime, timedelta
from datetime import date
from celery import shared_task,current_task, task
from celery import Celery
app = Celery()
@app.task
def test():
print ('1'
浏览 1提问于2019-07-30得票数 7
回答已采纳
我有一个运行Django应用程序的生产服务器
使用gunicorn和nginx运行Django服务器
pipenv run gunicorn --workers=1 --threads=50 --bind 0.0.0.0:8888 boiler.wsgi:application
芹菜工人用
pipenv run celery -A boiler worker
芹菜节拍是用
pipenv run celery -A boiler beat
现在，我已经更新了我的模型，并且我的生产服务器上很少有视图(例如，使用github进行了一些更改)
现在，为了反映更改，我应该重新启动所有的celery b
浏览 1提问于2021-01-26得票数 1
回答已采纳
1回答
姜戈芹菜击败任务不起作用
、、、、
celery.py
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from django.conf import settings
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'TwitterApiProxy.settings')
app = Celery('TwitterApiProxy')
app.config_from_object('dj
浏览 1提问于2018-04-06得票数 5
回答已采纳
2回答
我们正在运行一个用Django和Piston建立的网站，我想实现芹菜卸载任务到外部服务器。我并不是真的想在辅助服务器上运行Django，而是简单地运行一个纯Python celery worker。我是否可以在Django服务器上编写简单的函数存根，并在辅助服务器上编写实际的函数逻辑？
即
Django侧
from celery import task
@task
send_message(fromUser=None, toUser=None, msgType=None, msg=None):
pass
服务器端
from celery import Celery
celery =
浏览 0提问于2012-10-17得票数 2
回答已采纳
最近我注意到一种奇怪的芹菜(3.1.25)行为。一个任务只使用send_task()排队执行一次，但是过了一会儿，我看到多个任务正在运行！我花了几个小时研究芹菜文件，试图找出如何防止这种行为。任何帮助都将不胜感激！
这里是inspect active之外的
...
-> celery1@ec2-256-234-55-209.compute-1.amazonaws.com: OK
* {'hostname': 'celery1@ec2-256-234-55-209.compute-1.amazonaws.com', 'id':
浏览 1提问于2016-12-13得票数 5
假设我有三台服务器A，B & C，服务器C将有芹菜任务代码，我需要从服务器A&B执行它们。
从芹菜中，我看到有一个作为芹菜工人运行的task.py文件
from celery import Celery
app = Celery('tasks', broker='pyamqp://guest@localhost//')
@app.task
def add(x, y):
return x + y
然后我们有另一个python文件(比方说client.py)，它调用这些任务。
from tasks import add
add.dela
浏览 1提问于2020-04-22得票数 5
回答已采纳
3回答
试图了解芹菜如何与来自的狂犬病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
浏览 8提问于2016-02-03得票数 0
回答已采纳
1回答
如何在酒瓶上启动芹菜节拍
、、、、
我现在有一个类似于app.py的烧瓶代码
from services.celery_maker import make_celery
from flask import Flask
from datetime import timedelta
template_dir = os.path.abspath('./build/')
app = Flask(__name__, template_folder=template_dir, static_folder=os.path.abspath("./build/static"))
app.config['
浏览 0提问于2020-02-07得票数 1
回答已采纳
我能够创建celery_beat_schedule，并且它可以工作。耶！
但我想知道是否有任何方法为相同Django模型的不同对象创建cronjob。
Settings.py
CELERY_BEAT_SCHEDULE = {
'ok': {
'task' : 'bill.tasks.ok',
'schedule' : crontab(minute=27, hour=0),
# 'args' : (*args)
}
}
比尔/任务
from celery
浏览 0提问于2019-05-02得票数 1
回答已采纳
2回答
如何配置芹菜任务
、、、、
我在一个项目中使用了Celery，我将它作为一个调度器(作为周期性任务)。
我的芹菜任务如下所示：
@periodic_task(run_every=timedelta(seconds=300))
def update_all_feed():
feed_1()
feed_2()
...........
feed_n()
但是随着提要数量的增加，到达其他提要需要很长时间(例如，当芹菜使用提要编号n时，需要很长时间才能到达下一个提要(n+1)。我想使用Celery的并发性来启动多个提要。
看完文档后，我发现我可以调用一个芹菜任务，如下所示：
feed.delay()
浏览 2提问于2014-10-27得票数 1
1回答
我有一个Django应用程序，我的目标是通过红芹菜运行一个任务。
项目文件夹结构如下：
/mhb11/myfolder/myproject
├── myproject
│ ├── celery.py # The Celery app file
│ ├── __init__.py # The project module file (modified)
│ ├── settings.py # Including Celery settings
│ ├── urls.py
│ └── wsgi.py
├── manage.py
├── celeryb
浏览 1提问于2016-05-19得票数 1
回答已采纳
1回答
用监督器安装快拍
、、、
我很困惑如何使用芹菜拍与监督过程控制系统。下面的代码是supervisord上的celerybeat程序的一个示例。
; ================================
; celery beat supervisor example
; ================================
[program:celerybeat]
; Set full path to celery program if using virtualenv
command=celery beat -A myapp --schedule /var/lib/celery/beat.
浏览 6提问于2015-08-30得票数 1
回答已采纳
我正试着用芹菜在我的一个模型上执行一个相当耗用的算法。目前在我的home.tasks.py中有：
@shared_task(bind=True)
def get_hot_posts():
return Post.objects.get_hot()
@shared_task(bind=True)
def get_top_posts():
pass
在我的Post对象模型管理器中有：
def get_hot(self):
qs = (
self.get_queryset()
.select_related(
浏览 3提问于2020-07-05得票数 0
回答已采纳
我们希望在kubenetes集群中运行Celery/Redis，目前还没有启用Redis持久性(一切都在内存中)。我关心的是: Redis重启(丢失内存中的数据)、worker重启/中断(由于崩溃和/或pod调度)，以及短暂的网络问题。
在Redis中使用Celery进行任务处理时，需要做些什么来确保任务的可靠性？
浏览 34提问于2019-07-11得票数 0
1回答
我正在尝试执行一个定期任务，使用芹菜来删除那些没有及时激活账户的用户。下面的屏幕截图显示任务被正确发现和执行，但当我检查数据库时，没有进行任何更改。
芹菜任务：
#tasks.py
from celery.task.schedules import crontab
from celery.decorators import periodic_task
from celery.utils.log import get_task_logger
from .utils import unconfirmed_users_delete
logger = get_task_logger(__name__
浏览 0提问于2015-05-06得票数 0
2回答
我正在寻找一种方法，使def在我运行服务器时在某个时间值执行……每天一次的例子。一种解决方案是使用Celery，但我不想仅将其用于简单的定义……有什么建议吗？我用的是windows。谢谢!
浏览 0提问于2020-02-18得票数 0
2回答
在天数之间安排作业
、、、、
如何使用SQL Server代理作业将SSIS包安排在每月的10到17天之间？
在10号和17号之间，作业应该每30分钟运行一次。
查询：
SELECT
CASE
WHEN DATEPART(DD, GETDATE()) BETWEEN 10 AND 17
THEN 1
ELSE 0
END DAYSFLAG
我没有任何想法，如何将作业设置为仅在每月10和17号之间运行，每30分钟运行一次？
请告诉我如何在SQL Server代理作业中完成此任务。
浏览 6提问于2018-10-13得票数 1
我有一个酒瓶芹菜应用程序，实例化芹菜实例。我理解从.py文件的角度来看，我可以在同一个.py文件中添加一个普通的.py路径，并且我需要运行相同的代码两次：
运行工人：
芹菜工人-A app.celery .
运行与普通烧瓶应用程序相同的代码：
% python app.py .
我的问题是:如果普通的Flask应用程序是真正独立于芹菜应用程序的进程，那么我如何才能从一个烧瓶路径中操纵正在运行的芹菜实例来做以下事情：
celery.control.purge()
celery.control.inspect() etc ???
这是我的密码：
import os
impo
浏览 1提问于2017-02-10得票数 2
1回答
我想在特定的schedule.So上运行我的代码，我需要一个cron表达式，通过排除周六和周日来为每月的每12天安排一个作业(意味着只在工作日为每月的每12天安排一个作业)。这可以安排吗?？
有没有人能帮我解决这个问题？
浏览 2提问于2020-07-28得票数 1
我按照文档()编写了一个周期性任务，在django settings.py中添加CELERYBEAT_SCHEDULE，并在supervisor中运行它: celery -A proj worker -B
但现在我不再想要定期任务了。我删除了settings.py中的调度，并将superviosor中的命令更改为:没有芹菜节拍的celery -A项目工作者，然后重新加载它。
但是一旦我运行了celery，仍然会有周期性的任务在运行。
I事件删除djcelery和celery节拍pid文件中的所有数据。但这无济于事。
如何删除定期任务？
浏览 0提问于2017-04-14得票数 3
通过使用django-celery和后端djcelery.schedulers.DatabaseScheduler，我需要访问celery.task.PeriodicTask的最后运行时间
的旧文档说有一个类PeriodicClassMeta，它包含任务的元数据，包括last_run。然而，django-celery的文档并没有包含任何模型的使用信息或者如何设置PeriodicTasks。
所以，我的问题是，如何使用DatabaseScheduler后端在django-celery中设置PeriodicTasks，并访问与上次运行相关的元数据？
浏览 0提问于2013-03-28得票数 1
回答已采纳
1回答
假设我有一个模型Event。我想发送一个通知(电子邮件，推送，任何)给所有被邀请的用户一旦事件已经过去。与…有关的东西：
class Event(models.Model):
start = models.DateTimeField(...)
end = models.DateTimeField(...)
invited = models.ManyToManyField(model=User)
def onEventElapsed(self):
for user in self.invited:
my_notificati
浏览 3提问于2020-02-27得票数 11
回答已采纳
8回答
在我的Django项目中，我使用Celery和Rabbitmq在后台运行任务。我正在使用celery节拍调度器来运行周期性任务。如何以编程方式检查芹菜节拍是否已启动并运行？
浏览 1提问于2016-02-12得票数 15
>>> from app.tasks import SendSomething
>>> eager_result = SendSomething().apply()
为什么只有在shell中手动运行这个任务(manage.py shell)，我的任务才能工作？
settings.py
from datetime import timedelta
CELERYBEAT_SCHEDULE = {'send-something':
{'task': 'app.tasks.Send
浏览 1提问于2013-05-01得票数 0
回答已采纳
1回答
延迟执行芹菜任务
、、
我想把任务放到芹菜里，但我希望30秒后执行任务，而不是立即执行。
例如：
@celery.task
def task():
# waiting 30 seconds
do something....
我可以用它来制作它：sleep(30)，但是有更好的解决方案吗？
浏览 4提问于2015-12-09得票数 0
回答已采纳
3回答
我用的是celery.chord(...)创建一组任务和一个在该组中的所有任务完成后调用的方法。
我使用amqp结果后端(但我想切换到memcached)。
我的工人每秒一次又一次地打印这行代码。我不知道如何打破这个无限循环。我可以访问rabbitMQ web界面，但我找不到ID为"32ba5fe4-...“的内容。
[2013-03-22 14:18:26,896: INFO/MainProcess] Task celery.chord_unlock[32ba5fe4-918c-480f-8a78-a310c11d0c3a] retry: Retry in 1s
[2013-03-2
浏览 0提问于2013-03-22得票数 5
1回答
我正在管理一个通过Supervisor处理队列的芹菜工人。
下面是我的/etc/supervisor/celery.conf：
[program:celery]
command = /var/worker/venv/bin/celery worker -A a_report_tasks -Q a_report_process --loglevel=INFO
directory=/var/worker
user=nobody
numprocs=1
autostart=true
autorestart=true
startsecs=10
stopwaitsecs = 60
stdout_logfi
浏览 0提问于2015-03-12得票数 26
回答已采纳
我有5个文件，我想安排每月在windows7任务调度程序中运行。问题是我想让它们一个接一个地运行。
示例：
File1 (它首先运行) File2 (它在文件1运行完之后运行) File3 (它在文件2运行完成后运行)
以此类推。
我该怎么做呢？谢谢!
浏览 2提问于2012-03-09得票数 12
回答已采纳
我有一个简单的Django (v3.1)应用程序，我从表单接收数据，用视图处理数据，然后将其传递给芹菜(v4.4.7，RabbitMQ作为代理)。根据表单中提交的数据，它可以是一次任务，也可以是定期任务。
周期性任务应该执行与一次任务相同的任务，但是，嗯，有一个定期的时间表。我想把这个时间表传递给任务，包括一个开始日期、结束日期和一个空隙(例如:每2天下午4点执行一次，从现在开始到4周)。
我的观点(当然是为了说明而将其缩短和更名)：
# views.py
if request.method == 'POST':
form = BackupForm(request.P
浏览 8提问于2020-11-10得票数 8
在Linux中，每天、每周和每月运行/etc/crontab中的作业有时会运行
每日25 6***
每周47 6**7
52 6 1**月
我想在凌晨1点前调整时间。
有什么特别的理由把时间定在04:00以后还是06:00以后？
除了凌驾于一切的规则之外，我还需要注意任何事情吗？
浏览 0提问于2011-07-03得票数 3
我把姜戈和芹菜一起用。我需要关闭每天在协调世界时4点运行的celery.backend_cleanup。我一直在看文档，但找不到如何禁用它。下面是我的最后一次尝试：
celery.py
from __future__ import absolute_import, unicode_literals
from django.conf import settings
from celery import Celery
import os
os.environ.setdefault("DJANGO_SETTINGS_MODULE",
&#
浏览 0提问于2020-01-01得票数 2
2回答
我试图让用户安排一个周期性的任务。我还在一个容器里经营多个芹菜工人。我对容器的命令看起来如下所示：
celery worker -c 4 -B -l INFO -A my.celery.app.celery --scheduler my.celery.scheduler.SchedulerClass
但是所发生的是，当运行任务的时候，计划的任务运行了4次。
所以我读到你应该有一个专门的工作人员。我把我的命令改成了这个：
celery worker -c 4 -l INFO -A my.celery.app.celery
并添加了另一个与运行命令的容器完全相同的容器：
celery -l INF
浏览 0提问于2019-04-03得票数 3
1回答
在我的Django项目中，我在两个不同的应用程序中有两个任务，我想定期与芹菜一起运行。
工人似乎收集任务，节拍似乎收集调度。然而，节拍停留在开始(它没有同步的时间表)，从来没有交付任务给工人。
celery --app=bozonaro worker --loglevel=debug --beat (bozonaro是my项目的名称)命令提示我如下：
[2021-02-04 18:23:48,080: DEBUG/MainProcess] | Worker: Preparing bootsteps.
[2021-02-04 18:23:48,103: DEBUG/MainProcess] |
浏览 3提问于2021-02-04得票数 2
我正在做芹菜，使用rabbitmq服务器，在服务器上的django项目中创建了一个项目(消息队列，数据库存在)，它工作得很好，我还创建了多个工人
from kombu import Exchange, Queue
CELERY_CONCURRENCY = 8
CELERY_ACCEPT_CONTENT = ['pickle', 'json', 'msgpack', 'yaml']
CELERY_RESULT_BACKEND = 'amqp'
CELERYD_HIJACK_ROOT_LOGGER = True
C
浏览 0提问于2014-11-18得票数 25
我在使用current_app.send_task时遇到了芹菜队列路由问题
我有两个工作进程(每个队列一个)
python manage.py celery worker -E -Q priority --concurrency=8 --loglevel=DEBUG
python manage.py celery worker -Q low --concurrency=8 -E -B --loglevel=DEBUG
我在celeryconfig.py文件中定义了两个队列：
# -*- coding: utf-8 -*-
from __future__ import unicode_liter
浏览 5提问于2015-01-15得票数 1
3回答
我需要在特定的celeryd实例上运行一些任务。所以我配置了队列：
celeryconfig.py：
CELERY_QUEUES = {
'celery': {
'exchange': 'celery',
'binding_key': 'celery',
},
'import': {
'exchange': 'import',
'binding_key': '
浏览 0提问于2011-10-05得票数 3
回答已采纳
1回答
我有一个Flask应用程序，我可以在其中启动一个芹菜任务。这个任务是一种守护进程，我只想启动一次。所以当它启动时，我想要的就是监控它的状态，在任务中显示一些消息等等。这一切都运行得很好。
我不知道怎么做，是在flask应用程序中，一旦启动，我如何获取任务id。当我开始执行任务时，我可以完成
@main.route('/start', methods=['POST'])
def start():
task = long_task.apply_async()
# from here I know the id with 'task.id
浏览 1提问于2017-10-20得票数 0
我正在构建一个芹菜工人，打算每n秒只运行一次任务。我看到了日志语句。我看到了它的产卵过程。所以该方法正在被调用。
#portfolio-builder.py
from celery import Celery
from celery.task import periodic_task
from datetime import timedelta
REDIS_URL = "A PROPERLY FORMATTED REDIS URL APPEARED"
app = Celery('tasks')
app.conf.update(BROKER_URL=REDIS
浏览 0提问于2015-11-06得票数 1
首先，我知道所有的问题和答案，和
不幸的是，从我的测试中，我无法验证我提供的链接中记录的整个“任务在强制停止后继续运行”的观察结果。也许这个问题现在已经解决了？
无论如何，我试图完成的是只有在用户在强制停止后第一次打开他们的应用程序后才重新安排我的任务。
假设我有一个应该每月运行一次的任务。我想做的是只在应用程序第一次启动时调度它一次(通过once库)。此任务将正常运行，直到用户强制停止应用程序。在这一点上，我显然不关心任务没有运行，因为用户已经强制停止了它，但我确实希望在用户再次打开应用程序时立即重新调度该作业。
似乎在代码中没有明显的位置可以做到这一点。例如，如果我在应用程序类中这样做，任
浏览 0提问于2015-11-14得票数 0
2回答
我需要将一些数据从SQL Server传输到MySQL，每月一次。我已经做了这个传输的东西，但是我不知道(我也没有在互联网上发现)如何设置一个计时器来在每个月的特定日期执行这个传输。我不想仅仅设置一个以毫秒为单位的计时器间隔，因为每个月的天数都不同。
任何帮助我们都很感激。
浏览 0提问于2012-04-14得票数 0
回答已采纳
1回答
芹菜:停止工人之间的心跳
、、、
我正在用Redis后端和broker在芹菜中进行数据处理。许多工作人员(~200)与代理交互以获得任务并执行这些任务。然而，我的工人们都在互相发送心跳信号，用这样的巡航方式填充他们的日志：
[2018-05-13 15:38:00,737: INFO/MainProcess] missed heartbeat from celery@d12chas387.crc.nd.edu
[2018-05-13 15:38:00,737: INFO/MainProcess] missed heartbeat from celery@d12chas530.crc.nd.edu
[2018-05-13 15:
浏览 1提问于2018-05-14得票数 4
回答已采纳
2回答
不执行周期性任务
、、、
如何诊断为什么manage.py celerybeat不执行任何任务？
我是通过监督命令运行赛利贝特的：
/usr/local/myapp/src/manage.py celerybeat --schedule=/tmp/celerybeat-schedule-myapp --pidfile=/tmp/celerybeat-myapp.pid --loglevel=INFO
Supervisord看起来运行得很好，日志文件显示：
[2013-06-12 13:17:12,540: INFO/MainProcess] Celerybeat: Starting...
[2013-06-12 13:
浏览 5提问于2013-06-12得票数 18
1回答
我有两个服务器，芹菜工人正在运行。我们叫他们R1和R2。
在我的另一台服务器(例如R3)中，我希望创建链式任务，以便创建R1.任务，然后创建R2.任务子任务
但我很怀疑这是否可能。我试过了
# celery_apps.py on R3
from celery import Celery
from application.config import get_application_config
__author__ = 'hussain'
config = get_application_config()
celery_app_r1 = Celery(
'
浏览 10提问于2016-02-25得票数 0
回答已采纳
celery_app.conf.update(
CELERYBEAT_SCHEDULE = {
'taskA': {
'task': 'crawlerapp.tasks.manual_crawler_update',
'schedule': timedelta(seconds=3600),
},
'taskB': {
'task': 'crawlerapp.tasks.auto_crawler_update_day',
'schedule': timedelta(se
浏览 0提问于2014-10-07得票数 2
我有一个按钮，限制为每天5次，每月30次。每次点击它，它就会从每天剩下的和每月剩下的减少1。一旦它被点击5次，剩下的点击每天是0，他每月剩余的是25次。如何将此计数器每24小时重新设置为5在后台，即使应用程序没有运行或设备没有打开。在30天(月)之后，我如何做同样的事情。目前，我正在使用SharedPreferences来更新我想要更新的值。但我希望这是定期发生的，而不是每次应用程序启动时。
sharedPreferences.edit().putInt("dailyRemaining", dailyRemaining).apply(); //5
sharedPreferenc
浏览 7提问于2020-01-22得票数 1
回答已采纳
2回答
我被赋予了调度2个SSIS包的任务(顺便说一句，我是一个Jr.Data分析师，并且开始接触SSIS)。这是一个场景:我有一个包，需要安排在每周五下午1点运行(这会将文件发送给外部供应商)。我会称其为每周套餐。我为同一供应商准备了另一个包，需要安排在每个月的第一个星期五运行。这将称为月度套餐。因此，我计划每周包在每个星期五运行，但我需要每周包不运行每月包将运行的周五。任何想法都将不胜感激。谢谢
浏览 0提问于2014-01-23得票数 0
1回答
标题是不言而喻的。我想在每月初为用户创建一条新记录。在Django中实现这一点的最佳方法是什么？
我最初的想法是运行一个函数，该函数将每隔x个时间间隔检查一次日期和时间，然后如果最后一次记录的年份和月份!=，则创建一个新记录。这有可能吗？这种不断检查时间的做法似乎效率很低，但我正在努力想出另一种解决方案。
我的方向对吗？
浏览 11提问于2020-06-04得票数 0
1回答
我有一个非常简单的Flask应用程序示例，它使用芹菜工人异步处理任务：
app.py
app.config['CELERY_BROKER_URL'] = os.environ.get('REDISCLOUD_URL', 'redis://localhost:6379')
app.config['CELERY_RESULT_BACKEND']= os.environ.get('REDISCLOUD_URL', 'redis://localhost:6379')
app.config['SQLA
浏览 2提问于2020-12-04得票数 2
回答已采纳
1回答
我在一个服务器上有一个django应用程序+ redis，在另一个服务器上有芹菜。我想调用django应用程序的芹菜任务。
我在芹菜服务器上的task.py：
from celery import Celery
app = Celery('tasks')
app.conf.broker_url = 'redis://localhost:6379/0'
@app.task(bind=True)
def test():
print('Testing')
从Django服务器调用芹菜任务：
from celery import Celery
浏览 2提问于2022-09-29得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
