Acks_late:芹菜+ redis broker /后台
Acks_late是一个用于实时数据处理的技术概念，主要用于消息队列系统中。它结合了芹菜（Celery）和Redis Broker，用于处理后台任务。
- 芹菜（Celery）：芹菜是一个分布式任务队列系统，用于处理异步任务。它基于消息中间件（如Redis、RabbitMQ）实现任务的发布和消费，可以将任务分发到不同的工作节点进行处理。芹菜提供了简单易用的API和丰富的功能，使得开发者可以方便地编写和管理后台任务。
- Redis Broker：Redis是一个开源的内存数据库，也是一个高性能的键值存储系统。在Acks_late中，Redis被用作任务队列的中间件，负责存储和传递任务消息。通过将任务发布到Redis中，工作节点可以从中获取任务并进行处理。
Acks_late的优势：
- 异步处理：Acks_late可以将任务异步处理，不会阻塞主线程，提高系统的响应速度和并发处理能力。
- 分布式处理：通过芹菜和Redis的结合，Acks_late可以将任务分发到不同的工作节点进行处理，实现分布式的任务处理，提高系统的可扩展性和容错性。
- 高性能：Redis作为任务队列的中间件，具有高性能的特点，可以快速地传递任务消息，保证任务的及时处理。
Acks_late的应用场景：
- 后台任务处理：Acks_late适用于需要处理大量后台任务的场景，如异步邮件发送、数据处理、定时任务等。
- 实时数据处理：Acks_late可以用于实时数据处理，如日志分析、实时监控等。
- 分布式系统：Acks_late的分布式处理能力使其适用于分布式系统中的任务调度和处理。
腾讯云相关产品推荐：
- 云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 云数据库Redis版：https://cloud.tencent.com/product/redis
- 弹性消息队列（CMQ）：https://cloud.tencent.com/product/cmq
- 弹性MapReduce（EMR）：https://cloud.tencent.com/product/emr
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求进行评估和决策。
相关·内容
1回答
首先，请不要认为这个问题是的重复
我有一个设置环境，使用celery和redis作为broker和result_backend。我的问题是，我如何确保当芹菜工人崩溃时，当芹菜工人重新启动时，所有计划的任务都会重试。
我已经看到了关于使用CELERY_ACKS_LATE = True的建议，这样代理将重新驱动任务，直到它得到确认，但在我的例子中它不工作。每当我调度一个任务时，它就会立即转到worker，它会将它持久化到预定的执行时间。让我举一些例子：
我正在调度一个这样的任务：res=test_task.apply_async(countdown=600)，但在芹菜工人日志中，我立即可以看到类似
浏览 1提问于2013-01-19得票数 11
1回答
对于我们的Django网站之一，我们需要运行芹菜。
我们在settings.py中对芹菜使用以下设置
BROKER_URL = "redis://<ip address of the server>:6379/0"
CELERY_RESULT_BACKEND = "redis"
CELERY_REDIS_HOST = "<ip address of the server>"
CELERY_REDIS_PORT = 6379
CELERY_REDIS_DB = 0
Redis运行正常：
$ redis-cli ping
PO
浏览 2提问于2015-02-10得票数 0
我怎么能看到实时任务的执行？
我是芹菜新手。我在吃芹菜，但没有看到monitor标签
http://127.0.0.1:5555/monitor返回“未找到的页面”
我就是这样开始的
剧本中的芹菜
if __name__ == '__main__':
REDIS_TASKS_BROKER = 'redis://localhost:6379/0'
REDIS_TASKS_BACKEND = 'redis://localhost:6379/1
app = Celery(main=__name__, broker=REDIS_
浏览 2提问于2021-11-11得票数 4
我们使用Flower监控芹菜任务，在我们的项目中使用Redis作为代理。
当我们使用SSL作为代理配置Redis时，我们可以在broker选项卡中看到下一条消息：
不支持‘'redis’代理
我们试图(并成功地)通过下一个URL从芹菜连接到Redis：
rediss://{REDIS_HOST}:{REDIS_PORT}/{REDIS_DB_NAME}?{SSL_OPTIONS}
正如芹菜文档中所示。
同时，我们尝试了--broker和--broker_api参数，结果是相同的。
工作人员和任务工作正常(在工作人员内部，代理正常显示)，但是broker选项卡是空的。
如果我们查
浏览 2提问于2019-09-10得票数 2
1回答
我有一个简单的Python /芹菜应用程序，它在延迟后出现闪存消息的问题。我使用芹菜的delay()函数来调用一个休眠5秒的函数，然后闪烁一条消息。尽管在后台函数中使用了with app.app_context()，芹菜报告：
RuntimeError:在请求上下文之外工作
我也尝试过@copy_current_request_context装饰师，就像提到的那样，但是之后我得到了
RuntimeError:只有当请求上下文在堆栈上时，才能在本地作用域中使用这个装饰符。例如，在视图函数中
app.py:
from flask import Flask, flash, rende
浏览 3提问于2017-05-26得票数 3
回答已采纳
我在码头设置哨兵上遇到麻烦了。我发现的每一件事看起来都很老，很不推荐，在我试图逃跑的时候也有问题。
我使用的是docker编写的代码，如：
redis-master
image: redis:4.0.11-alpine
volumes:
- broker-data:/data
networks:
- db
ports:
- 6379:6379
redis-slave:
image: redis:4.0.11-alpine
command:
- redis-server --slaveof r
浏览 2提问于2020-01-03得票数 0
回答已采纳
当我建立容器形象时，我已经不能运行芹菜工人了。
dockercompose文件
version: "3.8"
services:
web:
build: .
ports:
- "8080:8000"
command: uvicorn app.main:app --host 0.0.0.0 --reload
environment:
- CELERY_BROKER_URL=redis://redis:6379/0
- CELERY_RESULT_BACKEND=redis://redis:63
浏览 60提问于2022-04-18得票数 0
当我在Django应用程序中使用RabbitMQ运行芹菜任务时，我的Heroku Dyno (业余爱好)已经达到了内存限制。 我对芹菜设置进行了一些尝试，但我总是遇到内存限制，并且我错过了内存优化的技术知识。我想知道是否有什么我可以做的，以防止我的当前设置达到限制，或者是唯一的解决方案，以升级Heroku Dyno？ BROKER_URL = 'amqp://url'
BROKER_POOL_LIMIT = 5
CELERY_RESULT_BACKEND = None
CELERY_MAX_TASKS_PER_CHILD = 10
CELERY_MAX_MEMORY_PER_
浏览 23提问于2020-01-26得票数 3
2回答
我和雷迪斯一起用芹菜。
当前Redis用作代理，并因此作为后端使用。
BROKER_TRANSPORT = 'redis'
BROKER_URL = 'redis://domain:8888/0'
CELERY_RESULT_BACKEND = 'redis://domain:8888/0'
我想澄清几件事：
使用结果后端有什么好处？我是说我用它会得到什么
我怎么才能看到它的作用呢？我是说什么东西会被储存在Redis里吗？那个仓库是永久性的吗？我怎么能质疑呢？那种储存会随着时间等而增长吗？
我能用芹菜花监控结果吗？
浏览 9提问于2016-05-03得票数 15
回答已采纳
我有django 3.2.7，芹菜5.2.1，redis 3.5.3 我有下一个芹菜设置。(REDIS_PASSWORD)是环境变量： CELERY_BROKER_URL = f'redis://:{REDIS_PASSWORD}@redis:6379/4'
CELERY_BROKER_TRANSPORT_OPTIONS = {'visibility_timeout': 3600}
CELERY_RESULT_BACKEND = f'redis://:{REDIS_PASSWORD}@redis:6379/1'
CELERY_ACCEPT_CO
浏览 29提问于2021-09-16得票数 0
2回答
我将芹菜-服务器3.0.0安装到烧瓶，然后启动服务器，但是当我使用服务器运行python代码背景时，我发现了这个错误。
~/局$ sudo python exme.py
回溯(最近一次调用)：
文件"exme.py"，第2行，在
从芹菜进口芹菜
ImportError:没有命名为芹菜的模块
from flask import Flask
from celery import Celery
app = Flask(__name__)
app.config.update(
CELERY_BROKER_URL='redis://localhost:6379',
浏览 3提问于2015-04-20得票数 0
回答已采纳
1回答
瓶用芹菜配置
、、、、
我已经将芹菜配置为在下面的开发框上为一个Flask应用程序运行异步作业：
config.py:
class CeleryConfig(object):
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_CONFIG = CeleryConfig
manage.py:
celery_app = celery.Celery(config_source=app.config.get('CEL
浏览 5提问于2017-01-01得票数 2
回答已采纳
1回答
我最近安装了芹菜和红葡萄酒，效果很好。然后，我尝试了同样的方法，将芹菜和红葡萄酒安装在码头容器内(selenium/独立的-chrome)，它不执行任务。
图如下所示：
它没有显示"INFO/MainProcess连接到redis ://127.0.0.1:6379/0.“，所以我不知道芹菜是否连接到redis。
tasks.py：
# -*- coding: utf-8 -*-
from celery import Celery
app = Celery(
'tasks',
broker='redis://127.0.0.1:6379/0'
浏览 1提问于2021-12-29得票数 1
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
1回答
芹菜工人的经营方式如下：
celery -A backend worker --broker=$REDIS_URL
花：
celery -A backend flower --broker=$REDIS_URL
当一个运行时，另一个工人的Flower决定了它。但是怎么做呢？例如，是否在Redis中存储了有关工人的信息？
浏览 6提问于2021-12-06得票数 1
我正在尝试在我的Django项目中设置芹菜4，我想让Redis作为代理。但我找不到Django特定的设置代理在芹菜4 ？此外，版本4的不再提到CELERY_BROKER_URL，我确信版本3的文档中确实提到了这些设置。
我在网上搜索了一下，发现了这些设置：
CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_R
浏览 3提问于2020-03-03得票数 0
1回答
我尝试为我的FastAPI项目实现芹菜，使用Redis作为代理和后端结果。我成功地构建了这个应用程序。但是，当我发送请求时，它会引发Error -3 connecting to redis:6379. Temporary failure in name resolution。这是我的docker-compose.yaml文件内容。我错过了什么？
顺便问一下，Redis末尾的/0是什么？
version: '3.5'
services:
soar-core:
container_name: soar-core
build: .
stdin_open:
浏览 32提问于2022-11-09得票数 0
回答已采纳
1回答
我有一个简单的芹菜task.py，运行着RabbitMQ message broker和Redis数据存储。
from celery import Celery
app = Celery('tasks', broker='pyamqp://guest@localhost//', backend="redis://localhost:6379/0")
@app.task
def add(x, y):
return x + y
和一个带有简单函数的listener.py服务
def on_add(result):
# Do som
浏览 7提问于2021-12-30得票数 1
回答已采纳
(venv) [riyad@Fury django_celery]$ celery -A django_celery worker -l info
<Celery django_celery at 0x7f0917d57fa0>
-------------- celery@Fury v4.3.0 (rhubarb)
---- **** -----
--- * *** * -- Linux-5.8.6-1-MANJARO-x86_64-with-glibc2.2.5 2020-09-30 02:54:36
-- * - **** ---
- ** ---------- [
浏览 1提问于2020-09-30得票数 2
回答已采纳
2回答
黑葵芹菜指南的澄清
、、、
我在试着找出的悲惨指令
在“配置芹菜应用程序”一节中，我不知道将代码放在哪里：
import os
app.conf.update(BROKER_URL=os.environ['REDIS_URL'],
CELERY_RESULT_BACKEND=os.environ['REDIS_URL'])
我们非常感谢对这些指示的任何澄清。
浏览 4提问于2019-11-15得票数 0
回答已采纳
2回答
目前，我创建了一个芹菜工人+花卉监控解决方案，基于
芹菜工人和花朵监控都运行在相同的目录flask-celery中
原因是，Flower可以访问Celery worker代码模块，且以下带有-A标志的命令可以正常工作
entrypoint: flower
command: -A tasks --port=5555 --broker=redis://redis:6379/0
这是他们的的样子
worker:
build:
context: ./flask-celery
dockerfile: Dockerfile
depends_on:
- redis
moni
浏览 4提问于2018-02-05得票数 6
1回答
芹菜花如精灵
、、
我经营芹菜和红色后端。我想把芹菜花作为守护进程运行在centos 6.2上。
我知道花是龙卷风的应用程序，所以我应该使用一个进程来运行龙卷风应用程序。
通常情况下，我使用以下命令来启动flower：
芹菜花-broker=redis://localhost
我在下面的链接中看到，我需要创建这样一个python脚本： (Startflower.py)
import tornado.ioloop
import tornado.web
import tornado.httpserver
if __name__ == "__main__":
http_server
浏览 1提问于2012-11-27得票数 15
回答已采纳
1回答
在设置了芹菜、Redis和flower之后，我做了一些基本测试，使用默认的celery队列，一切正常工作。在此之后，我创建了一些自定义队列，然后flower无法监视这些自定义队列。我认为flower继续监视celery队列。虽然，花可以正确地监测结果。
芹菜项目报告：
software -> celery:4.2.1 (windowlicker) kombu:4.2.1 py:2.7.15rc1
billiard:3.5.0.4 redis:2.10.6
platform -> system:Linux arch:64bit imp:CPython
load
浏览 0提问于2018-10-26得票数 2
回答已采纳
我在k8吊舱里跑着一只芹菜。这是我的芹菜清单
apiVersion: apps/v1
kind: Deployment
metadata:
name: celery
labels:
deployment: celery
spec:
replicas: 2
selector:
matchLabels:
pod: celery
template:
metadata:
labels:
pod: celery
spec:
containers:
- name: celery
浏览 10提问于2021-02-20得票数 3
1回答
我有下面的芹菜配置
celery = Celery(__name__,
broker=os.environ.get('CELERY_BROKER_URL', 'redis://'),
backend=os.environ.get('CELERY_BROKER_URL', 'redis://'))
celery.config_from_object(APP_SETTINGS)
ssl = celery.conf.get('REDIS_SSL', True)
r = redis.StrictRedi
浏览 7提问于2019-11-07得票数 0
我有一个芹菜工人，被配置成与redis连接，如下所示：
celery_app_site24x7 = Celery('monitoringExterne.celerys.site24x7',
broker=settings.REDIS['broker'], backend=settings.REDIS['backend'])
celery_app_site24x7.conf.broker_transport_options = {
'visibility_timeout&
浏览 2提问于2020-01-14得票数 2
回答已采纳
1回答
tasks.py
from celery import Celery
app = Celery('tasks',
broker='redis://localhost',
backend='redis://localhost',
include=['tasks'])
app.conf.broker_url = 'redis://localhost:6379/0'
# Optional configuration, see the
浏览 1提问于2017-05-11得票数 1
1回答
我有一个Django应用程序，它使用Celery和Redis broker进行异步任务执行。目前，该应用程序的3队列 (& 3个工作人员)连接到单个Redis实例进行通信。在这里，前两个工作人员是基于预叉的工作人员，第三个是工作人员。
与代理和后端有关的芹菜设置变量如下所示：
CELERY_BROKER_URL="redis://localhost:6379/0"
CELERY_RESULT_BACKEND="redis://localhost:6379/1"
由于芹菜使用实现FIFO队列，我想知道对于不同的队列使用不同的Redis数据库是否正确，甚至是
浏览 2提问于2021-01-08得票数 1
回答已采纳
1回答
我正在运行一个Flask应用程序，它运行几个芹菜任务(使用Redis作为后端)，有时还会用Flask缓存缓存API调用。它将在Heroku上运行，尽管目前我正在本地运行它。我正在试图找出是否有一种方法可以重用我的各种配置变量用于Redis访问。主要是为了防止Heroku更改凭据，将Redis移动到另一台服务器，等等。目前，我正在以多种方式重用相同的Redis凭据。
从我的.env文件：
CACHE_REDIS_URL = "redis://127.0.0.1:6379/1"
REDBEAT_REDIS_URL = "redis://127.0.0.1:6379/1
浏览 14提问于2022-08-10得票数 0
回答已采纳
1回答
我在我的Digital Ocean VPS上使用芹菜和Redis broker。我对Celery和Ubuntu是个新手，所以也许有一个简单的解决方案。
我更改了一个Django任务，它看起来像是芹菜使用了旧版本。因此，我尝试使用redis-server shutdown重启celery和芹菜，并终止redis进程。
问题是，现在，什么都不起作用。当我运行redis-cli或尝试检查芹菜状态(有运行的supervisord)时，它似乎冻结了。
如您所见，这两个命令都没有响应。
我该怎么办？我正在考虑重新启动VPS，但我不确定它是否不会造成任何伤害。
浏览 10提问于2017-01-26得票数 0
1回答
我在测试Django +芹菜，你好世界的例子。对于RabbitMQ，芹菜效果很好，但是当我切换到Redis /result时，我得到了如下结果：
%timeit add.delay(1,2).get()
1 loops, best of 3: 503 ms per loop
settings.py
CELERY_RESULT_BACKEND = "redis"
BROKER_URL = 'redis://localhost:6379'
tasks.py
@task()
def add(x, y):
return x + y
上面的测试有什么问题吗？
浏览 1提问于2013-03-13得票数 0
回答已采纳
这个问题不言自明--django--芹菜--结果不存储任何任务结果。
我按照文档中“入门”部分的描述做了所有事情，但仍然没有结果。
我使用django 4.1.2和django-芹菜-结果2.4.0
下面是来自settings.py的相关变量：
CACHES = {
'default': {
'BACKEND': 'django.core.cache.backends.redis.RedisCache',
'LOCATION': 'redis://redis:6379',
浏览 7提问于2022-11-25得票数 1
1回答
目前，我正试图使用带有Redis url的pycelery在金字塔文件中运行芹菜任务，这本身就是一个环境变量，因此我尝试如下所示：
[celery]
BROKER_URL = ${REDIS_URL}
但是当我运行它时，我会得到错误。
这表明BROKER_URL没有识别环境变量。但在文件的前面我可以声明
redis.url = ${REDIS_URL}很好。任何帮助都将不胜感激。谢谢!
浏览 3提问于2016-07-12得票数 1
回答已采纳
我在heroku/git上为我的Django项目配置了以下芹菜- os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'App.settings')
app = Celery('App')
app.conf.timezone = 'Europe/London'
app.config_from_object('django.conf:settings')
app.conf.update(BROKER_URL=str(os.getenv('REDIS_URL
浏览 52提问于2021-07-21得票数 2
1回答
芹菜任务定义如下：
from celery.decorators import task
@task(name="send_email")
def send_email(email, host):
像这样调用它时，Django会被卡住：
send_email.delay(email, host)
就像没有异步运行一样，
我遗漏了什么？
这些是一些芹菜的设置，它使用redis做经纪人：
>>> settings.CELERY_ACCEPT_CONTENT
[u'application/json']
>>> settings.C
浏览 1提问于2018-08-23得票数 0
我在使用python flask应用程序工厂应用程序实现celery时遇到了问题。
我打算从应用程序init文件创建一个芹菜应用程序的实例，如下所示：
from celery import Celery
celery = Celery('myapp', broker='redis://localhost:6379/0', backend='redis://localhost:6379/0')
当被调用时，我不能使用其他蓝图中的芹菜。
浏览 2提问于2019-10-24得票数 3
我有个简单的芹菜任务。为了运行它，我首先启动了redis服务器，然后激活了虚拟env并输入了“芹菜节拍”，打开了一个进入虚拟env的新终端窗口，并输入了“芹菜工人”。
Flask==1.0.2
celery==4.2.1
requests==2.19
这是之后的错误消息：
使用者:无法连接到amqp://来宾：**@127.0.0.1:5672//: timed。
这是执行“芹菜节拍”后显示的配置细节：
配置->。代理-> amqp://来宾：**@localhost:5672//。装载机-> celery.loaders.default.Loader .调度器-&
浏览 0提问于2018-08-02得票数 0
回答已采纳
根据芹菜在使用Redis后端时的结果调查，默认情况下使用0.5s间隔。
天真的开发人员可能会认为，任何使用Redis的排队系统至少都会试图利用其LIST或PUBSUB机制。为什么芹菜不这样做，而是依靠民意测验？
例如，当运行芹菜工人(这是默认的轮询间隔)时，以下代码在调用上取精确的0.5秒：
from celery import Celery
app = Celery('tasks', broker='redis://localhost:6379/0',
backend="redis://localhost:6379/0&#
浏览 2提问于2014-03-12得票数 4
回答已采纳
在我的Django项目中，我根本不使用SQL数据库，我的主要数据存储是MongoDB，通过。
我想设置芹菜作为经纪人和后端与Redis一起工作。我安装了，安装了Redis (本地和生产)，并尝试在我的settings.py中使用以下内容：
BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = BROKER_URL
import djcelery
djcelery.setup_loader()
但是当我运行芹菜过程时，它收到了一个要处理的任务，当返回结果时，它抱怨settings.DATABASES配置不当
浏览 4提问于2013-07-17得票数 1
我正在部署一个Django应用程序，它使用芹菜任务，并有redis作为代理后端。我使用docker进行部署，我的生产服务器是一个amazon aws实例。我面临的问题是，本地主机的django设置是不同的：
BROKER_URL = 'redis://localhost:6379' CELERY_RESULT_BACKEND = 'redis://localhost:6379'
我所有的单元测试都能正常工作。对于docker，它会失败，除非我将它更改为
BROKER_URL = 'redis://redis:6379' CELERY_RESULT
浏览 11提问于2017-01-21得票数 0
回答已采纳
1回答
下面是我的简化网站应用程序和芹菜设置
app = Flask(__name__)
celery = Celery(__name__, broker='redis://localhost:6379/0')
celery.conf.update({app.config})
和其他芹菜吐露
CELERYD_MAX_TASKS_PER_CHILD=1
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CEL
浏览 2提问于2019-09-08得票数 0
回答已采纳
摘要
我正在通过celeryd ()作为守护进程运行芹菜。
指定redis作为配置文件/etc/default/celeryd BROKER_URL=中的代理“redis://localhost:6379/0”
辅助日志文件表示BROKER_URL仍试图连接到默认代理时被忽略。
错误/MainProcess]使用者:无法连接到amqp://来宾：**@localhost:5672//:错误打开套接字:发生套接字错误。
问题：是否需要修改/etc/init.d/celeryd文件，而不是在线说明中提供的基本模板，以便将BROKER_URL作为参数传递？
浏览 0提问于2016-07-09得票数 0
1回答
芹菜不加烧瓶
、、、、
我在烧瓶应用程序中使用芹菜，但芹菜(3.1.8).This是我配置的烧瓶应用程序
celery.py
from __future__ import absolute_import
from celery import Celery
from cuewords.settings import CELERY_BROKER_URL,CELERY_RESULT_BACKEND
app = Celery('proj',
broker=CELERY_BROKER_URL,
backend=CELERY_RESULT_BACKEND)
app.
浏览 4提问于2014-02-19得票数 4
回答已采纳
我有以下脚本：
celery_tasks.py
from celery import Celery
app = Celery(broker='amqp://guest:guest@localhost:5672//')
app.conf.task_default_queue = 'test_queue'
@app.task(acks_late=True)
def test(a):
return a
publish.py
from celery_tasks import test
test.delay('abc')
当我运行publish.p
浏览 0提问于2018-09-18得票数 0
1回答
我正在尝试运行气流芹菜工人与redis后端，但无法得到之间的工人和redis之间的工作。
下面是配置的样子：
broker_url = redis://:<my-password>@localhost:6379/0
我收到错误消息：
ValueError: invalid literal for int() with base 10: 'my-password-string'
有人知道解决这个问题的方法吗？
浏览 1提问于2020-05-31得票数 0
2回答
我已经免费试用了Redis，它给了我一个端点和密码。我以前没有用Redis或芹菜做过任何事情，所以我真的不知道它是如何工作的。从芹菜的文档中，每个人都连接到本地主机，但是我如何连接到这个端点？ CELERY_BROKER_URL='redis://localhost:6379',
CELERY_RESULT_BACKEND='redis://localhost:6379' 我应该用什么替换它？我应该在哪里提供密码？ 我的端点看起来像这样：redis-18394.c252.######.cloud.redislabs.com:18394，我应该在/之后在这个端点
浏览 38提问于2021-06-23得票数 1
我无法导入芹菜应用程序来从我的主要Python应用程序运行任务。我希望能够从myprogram.py文件中运行芹菜任务。
我的celery_app.py文件如下：
import celery
app = celery.Celery('MyApp', broker='redis://localhost:6379/0')
app.conf.broker_url = 'redis://localhost:6379/0'
app.conf.result_backend = 'redis://localhost:6379/0'
app.
浏览 3提问于2017-11-07得票数 1
我正在构建一个酒瓶应用程序，它依赖芹菜来处理一些长期运行的任务。每个任务都会在完成处理后将字典附加到共享列表中--这个列表由芹菜工人和烧瓶应用程序的路线共享。Flask组件本质上由一组路由组成，用于检索共享列表的内容并修改元素的顺序。
我使用Python的多处理模块的Manager成功地在芹菜工人之间共享了列表。但是，对这个列表所做的更改没有被Flask应用程序看到。下面是一个很小的应用程序，它说明了这个问题：
import os
import json
from flask import Flask
from multiprocessing import Manager
from cele
浏览 2提问于2016-03-04得票数 3
回答已采纳
1回答
在芹菜中有没有一种干净的方法来知道它的代理和/或结果后端是否停机？ 我正在使用RabbitMQ broker和Redis后端的芹菜。 目前，我发现的最简单的方法是提交一个虚拟任务，它会在代理宕机时引发kombu.exceptions.OperationalError，并在后端宕机时引发redis.exceptions.ConnectionError。 然而，这感觉有点老生常谈。有没有更好的方法？
浏览 52提问于2019-03-22得票数 0
回答已采纳
我想在Windows上开发一个python应用程序，它将使用Redis作为芹菜的代理。假设我的应用程序可以与我在Linux的Windows子系统上安装的Redis实例进行交互是正确的吗？
我已经在Windows 10上为Linux启用了Windows子系统，并在其上安装了Ubuntu和Redis，并启动了服务器。在Windows方面，我使用VSCode编写python代码。如下所示，在python代码中，我试图连接localhost上的Redis :6379
from celery import Celery
BROKER_URL = 'redis://localhost:6379/
浏览 2提问于2019-05-18得票数 11
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
