message-queue 相关问题

尝试第一次启动 Celery 但出现如下错误，我已经安装了 redis 并且它启动正常，但是 django 似乎仍然有问题，文件“ 尝试第一次启动 Celery 但出现如下错误，我已经安装了 redis 并且它启动正常，但是 django 似乎仍然有问题， File "<frozen importlib._bootstrap_external>", line 848, in exec_module File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed File "/home/atif/Documents/celery_test/celery-env/lib/python3.8/site-packages/kombu/transport/redis.py", line 263, in <module> class PrefixedStrictRedis(GlobalKeyPrefixMixin, redis.Redis): AttributeError: 'NoneType' object has no attribute 'Redis' 芹菜.py from django.conf import settings os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'celery_test.settings') app = Celery('celery_test',) app.config_from_object('django.conf:settings') # Load task modules from all registered Django apps. app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) @app.task(bind=True) def debug_task(self): print(f'Request: {self.request!r}') 设置 #celery stuff --------------- BROKER_URL = 'redis://localhost:6379' CELERY_RESULT_BACKEND = 'redis://localhost:6379' CELERY_ACCEPT_CONTENT = ['application/json'] CELERY_TASK_SERIALIZER = 'json' CELERY_RESULT_SERIALIZER = 'json' CELERY_TIMEZONE = 'Asia/Kolkata' celery_module/tasks.py from celery import Celery app = Celery('tasks',) @app.task def add(x, y): return x + y 尝试在虚拟环境中安装Redis： pip install Redis 使用全局安装redis pip install redis 或（如果您使用pipenv）我的情况出现错误是因为运行时未使用环境中的redis包 python -m celery -A *django_app* worker 如果你使用pipenv来管理你的Python环境，你可以运行上面的命令： pipenv run python -m celery -A *django_app* worker 如果你使用 Docker Compose，我帮助将reduce 添加到requirements.txt

django redis celery message-queue django-celery

回答 3 投票 0

RabbitMQ - ACCESS_REFUSED - 登录被拒绝

我正在使用rabbitmq-server并使用用Scala编写的消费者从中获取消息。这一直很有效，但自从我将 RabbitMQ 服务器从一台服务器迁移到另一台服务器后，我得到了

authentication rabbitmq message-queue

回答 3 投票 0

发布消息时 RabbitMQ 访问被拒绝 - 如何授予用户特定队列的权限？

我在全新安装的 RabbitMQ 上设置了一个非常基本的队列“test_queue”，并创建了一个基本的非管理员用户“user”（我已为其授予与管理员帐户相同的虚拟主机访问权限）。什...

rabbitmq message-queue

回答 2 投票 0

如何一次只处理一条给定类型的消息？

我有多个生产者，它们产生处理组件的请求。这些组件有很多，每一个组件的处理都需要大量时间。问题是有...

rabbitmq message-queue messaging amqp

回答 2 投票 0

RabbitMQ - 多个消费者单个发布者

当使用RabbitMQ处理大量消息时，我需要为同一个发布者和任务添加多个消费者。 RabbitMQ 和网络上的大多数教程都建议注册多个

java rabbitmq message-queue

回答 1 投票 0

rabbitmq如何同步消息？

我使用 pika 使用这个简单的代码： conn = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) 通道 = conn.channel() def on_message(ch, 方法, 属性, 消息): 打印（“

python rabbitmq message-queue pika python-pika

回答 1 投票 0

在 RabbitMQ 中通过属性或标头获取消息

我是 RabbitMQ 的新手，我遇到了一个问题。我正在尝试通过 API 方法从队列中获取消息。我已经做到了，现在我想通过标头或属性从队列中获取消息（如果可能的话）...

rabbitmq message-queue messaging

回答 2 投票 0

RabbitMQ 本地主机管理无法启动，日志文件中出现端口 5672 错误

我已经在Windows 10机器上安装了RabbitMQ 3.11.2和Erlang版本25.1.1。我对 RabbitMQ 非常陌生，无法启动 RabbitMQ 管理门户。我启用了 RabbitMQ 管理...

rabbitmq message-queue messagebroker rabbitmq-exchange

回答 2 投票 0

Linux Posix 消息队列：消息太长

我想做的是，当子进程在文件上找到素数时，父进程应该将它们写入另一个文件。子进程将发送素数作为 M 个数字的消息。然而我却无能为力...