Вопросы с меткой [rabbitmq]
RabbitMQ — платформа, реализующая систему обмена сообщениями между компонентами программной системы (Message Oriented Middleware) на основе протокола AMQP (Advanced Message Queuing Protocol).
114
вопросов
0
голосов
0ответов
15 показов
Проблема с rabbitmq
Я тут попробовал поиграться с rabbitmq.
Но я столкнулся с проблемой, когда пробую подключиться к нему(rabbitmq), у меня вылазит ошибка:
pika.exceptions.IncompatibleProtocolError: StreamLostError: ('...
1
голос
0ответов
28 показов
Запуск фоновых задач через dramatiq
@dramatiq.actor(store_results=True)
def count_words(url):
try:
response = requests.get(url)
count = len(response.text.split(" "))
print(f"...
0
голосов
0ответов
27 показов
RabbitMQ записать данные в БД
_consumers.SubscribeAsync(Do); это строка вызывает же function Do ? и передат аргумент Account да? или я ошибаюсь?
в function Do я вызываю method который должен зарисать эти данные в базу но не пишет.
...
1
голос
0ответов
59 показов
Подтверждение обработки сообщения из очереди RabbitMQ
Организую для взаимосвязи приложений очередь.
Использую библиотеку aio-pika для того, чтобы получать сообщения.
Проблема:
Сообщения успешно получаю и обрабатываю их, НО по средствам мониторинга вижу, ...
0
голосов
1ответ
47 показов
Как правильно реализовать систему очередей для асинхронного подтверждения авторизации, путем ожидания кода
Имеется puppeteer сервер который выполняет авторизацию на сервере, он служит в качестве удобной авторизации над сервисом, предлагая возможность в качестве мультиаккаунтности. Проще говоря, свой сервис,...
0
голосов
0ответов
9 показов
Nameko RPC имеет не достаточную пропускную способность, как улучшить?
Решился попробовать микросервисную архитектуру, я использую Flask + UWsgi + nginx для apigateway и Rabbitmq + Nameko + Python для связи с сервисами.
В итоге заметил такую проблему, Nameko создает в ...
0
голосов
0ответов
22 показа
Не работает переопределение on_decode_error для Consumer
Доброй ночи всем. Вот кусок кода Python модуля: customworker.py
from celery import Celery, bootsteps
from kombu import Consumer, Exchange, Queue
QUEUE = Queue(
name='custom_worker_test',
...
0
голосов
0ответов
37 показов
Настройка федерации для rabbitmq
Есть два vhost для rabbitmq: / и /api. Сообщения приходят на vhost /api. Необходимо настроить обмен между федерацией на /api и очередью на /
Настроил федерацию, связал с exchange и очередью на хосте /...
0
голосов
1ответ
49 показов
Как отправить сообщение всем слушателям RabbitMQ, Spring boot
Отправка:
@Service
public class ProducerImp implements Producer {
@Autowired
private AmqpTemplate amqpTemplate;
@Value("${jsa.rabbitmq.exchange}")
private String exchange;
...
0
голосов
0ответов
53 показа
Я не понимаю как настроить celery и rabbitmq на Windows
Сейчас покажу код, делаю на ubuntu все то же самое, что и на Windows
Windows код не исполняет, не отправляет email, с ubuntu этот же проект работает прекрасно.Как заставить работать celery на windows?
...
0
голосов
0ответов
21 показ
Почему происходит сброс по таймауту?
Есть 2 сервера на ubuntu 18.04. На одном расположен софт, на другом rabbitmq. При запуске запуске приложения, происходит очень долгое подключение к rabbitmq, в логах пишет, что не может подключится. ...
0
голосов
0ответов
9 показов
add_before_body в Nginx
Есть задача отправки событий напрямую в очередь в RabbitMQ.
В API Rabbitmq указано, что отправляемое событие должно быть вида
'{"properties":{},"routing_key":"my key",&...
0
голосов
0ответов
26 показов
Как синхронизировать работу нескольких rabbit worker-ов?
Есть ситуация:в очередь падают сообщения и worker (далее обработчик) берет их в работу (rabbit).
Сообщение такого формата:
{
"id": "16dfc6da-d6fc-421c-9a93-245c12b07d27",
&...
1
голос
2ответа
52 показа
Как асинхронно вызвать синхронный метод?
Насколько я понимаю в текущей реализации библиотеки RabbitMQ.Client (https://www.nuget.org/packages/RabbitMQ.Client/) для c# нет асинхронного варианта для метода BasicPublish.
Я хотел бы что бы вызов ...
0
голосов
1ответ
38 показов
Установить RabbitMQ для Laravel 5.8. Ошибка composer - Your requirements could not be resolved to an installable set of packages
Всем заглянувшим, доброго времени суток!
Сам сервер запускается и работает нормально(Docker).
Но при добавлении данной либы через composer composer require vladimir-yuldashev/laravel-queue-rabbitmq ...
0
голосов
0ответов
33 показа
Вернуть ответ клиенту из после RabbitMQ
Есть сервер, который принимает запрос от клиента и отправляет в RabbitMQ, есть слушатель, который получает сообщения из очереди, обрабатывает его и должен обратно вернуть клиенту.Вопрос в том, как ...
0
голосов
0ответов
25 показов
pika в одном котнейнере не взаимодействует с rabbitmq в другом
Я пытаюсь через docker-compose запустить два сервиса. Один сервис это rabbitmq а второй это python код test, который должен добавлять один запрос в очередь rabbit'а с помощью pika.
При запуске через ...
0
голосов
0ответов
14 показов
Отправка сообщения внутри callback функции
Есть слушатель очереди, который вызывает callback функцию preparePCRFRequest :
$channel = $this->RabbitConnection->channel();
$channel->queue_declare('test', false, true, ...
0
голосов
0ответов
22 показа
Долгий ответ heartbeats от клиента Node.js при публикации сообщений
Столкнулся с проблемой провалов heartbeats от клиента Node.js (npm-пакет amqplib) при публикации >150к уникальных сообщений в 20 символов каждое.
Отправляю сообщения в цикле следующим кодом:
// ...
0
голосов
0ответов
30 показов
Установка параметра Heartbeat при коннекте к RabbitMQ через Amqplib
При коннекте к RabbitMQ через amqplib не удается установить значение параметра Heartbeat.
Делаю так:
// Модули NPM
const amqp = require('amqplib/callback_api');
const withAutoRecovery = require('...
0
голосов
1ответ
33 показа
Нужно ли использовать очереди в node.js
Я слышал, что в python и php на бекенде используются очереди, в питоне это например rabbitmq.
Нужно ли использовать подобные очереди или node.js в виду своей ассинхронности в таком не нуждается?
1
голос
0ответов
40 показов
SignalR клиент не получает сообщения через MassTransit
У меня есть проблема с отправкой сообщений клиентам SignalR через MassTransit.
Всё сделано согласно документации.
Есть Сервис А, который генерирует событие. Данное событие через MassTransit ловит ...
0
голосов
0ответов
16 показов
Получить сообщение от consumer
Начал смотреть RabbitMQ и возник такой вопрос, есть код, который слушает сообщения и выводит. Вывод происходит благодаря callback функции. $callback = function ($msg) { echo ' [x] Тело сообщения ', $...
0
голосов
0ответов
86 показов
RabbitMQ (Неверно задано имя папки)
Нужно установить RabbitMQ, а не выходит
Следую инструкциям вот отсюда: https://afedyanin.wordpress.com/2014/11/06/rabbitmq-how-to-install/
и на 6 пункте, когда нужно перезапустить RabbitMQ мне выдает ...
0
голосов
0ответов
7 показов
RabbitMQ connect to epmd
Установил RabbitMQ на VPS хостинг. Система CentOS 7.
При вызове hostname выдает - 10231.vm.host.ws .
И при запуске RabbitMQ, получаю следующий конфуз
unable to connect to epmd (port 4369) on ...
0
голосов
0ответов
57 показов
Не запускается flower python
При запуске flower выходит данная ошибка, не могу понять в чем дело, может кто нибудь сталкивался с подобным? Пишу интернет магазин на django в связке с rabbitmq и celery
(venv) PS D:\myinternetshop\...
0
голосов
2ответа
30 показов
Можно ли в rabbitmq сделать какие-то периодические задачи?
Например, каждый час добавляет одно и тоже сообщение в заданную очередь или эксчендж? без крона
0
голосов
1ответ
50 показов
0
голосов
1ответ
66 показов
Как правильно распределять запросы по микросервисам?
Допустим в качестве брокера запросов к микросервисам использую Кафка или Rabbit или что то другое.
Пока выбираю что использовать.
Но я не понимаю на основании чего брокеры знают каким именно сервисам ...
1
голос
0ответов
51 показ
Повторная обработка сообщений в RabbitMQ, Golang
Смотрю пример работы с rabbitMQ на Go.
Код из примера
На основе этого примера написал свой код. Я беру сообщения из очереди и отправляю их на сторонний сервис для обработки. Если не произошло ошибок, ...
1
голос
0ответов
30 показов
Python Celery как он поведет себя при использовании с внешним брокером
пытаюсь разобраться в Celery (с брокером rabbitmq), чтобы понять, стоит ли использовать его для моих проектов.
Допустим есть периодический таск, который записывает в файл каждые 10 секунд время:
from ...
2
голоса
1ответ
73 показа
Теряются задачи
Всем привет, использую в проекте Django, Celery и RabbitMQ. Заметил, что при большой нагрузке кол-во Processed не равно кол-ву Succeeded + Failed.
Например сейчас
Processed: 1598741
Succeeded: 1598591
...
1
голос
2ответа
375 показов
Как в Django проекте в Docker корректно установить и запустить Celery c RabbitMQ?
Всем привет! Проект на Django. Использую Docker. Нужно установить и подключить к проекту Celery и RabbitMQ.
Dockerfile
FROM python:3.7-slim
ENV PYTHONDONTWRITEBYTECODE 1
ENV PYTHONUNBUFFERED 1
...
0
голосов
0ответов
41 показ
RabbitMQ блокирует поток на входящие данные. C#
Сразу извиняюсь за не полную инфу по вопросу. Не знаю всех тонкостей библиотеки которая поставляет данные, собственно с ней и проблема при работе с RabbitMQ.
Библиотека поставляет биржевые данные. ...
0
голосов
1ответ
112 показов
yii2 queue перезапускает всю очередь вместо конкретного сообщения
Пытаюсь реализовать очередь на rabbitmq в Yii2 используя стандартную yii2-queue
Допустим в очереди есть сообщения 1, 2, 3, 4 и если в каком-то из сообщений возникает ошибка (например 3) мы не ...
0
голосов
0ответов
252 показа
Очередь отложенных сообщений
Появилась задача, сделать демона, который будет выполнять задачи по расписанию. Сначала я думал все эти задачи сохранять в таблицу и демон чтобы их выполнял как время подходит. Но также нужно ...
1
голос
1ответ
140 показов
Гарантированная доставка сообщений
Сейчас разбираюсь с RabbitMQ. Ну и везде куча слов, типа сообщение после попадания в очередь живет, пока не будет обработано. Сообщение переживает как перезапуск читателя, так и всего брокера и т.д.
...
1
голос
0ответов
85 показов
Выскакивает TimeoutException com.rabbitmq.client.impl.ForgivingExceptionHandler.log
второй день не получается победить ошибку. сам таймаут по умолчанию 5 сек
java.util.concurrent.TimeoutException
29-Oct-2019 20:05:21.408 WARNING [AMQP Connection 127.0.0.1:5672]
com.rabbitmq.client....
0
голосов
0ответов
37 показов
Работа в RabbitMq (MassTransit) в консоли
Есть такой код ресивера:
class Program
{
public static IBusControl BusControl;
static void Main(string[] args)
{
try
{
BusControl =...
2
голоса
0ответов
51 показ
rabbitmq - можно ли устанавливать размер очереди?
Можно ли в rabbitmq устанавливать размер очереди? Например в 1к сообщений.
И все последующий поступающие сообщения вытесняли первые?
Новое сообщение поступило - самое старое стерлось.
0
голосов
0ответов
46 показов
помогите разобраться с CELERY
Вопрос такой:
по туториалу пытаюсь создать е-маркет на django. и для отправки сообщений об удачном заказе установил Celery в комплекте с Rabbitqm. в главной директории проекта создал файл celery.py и ...
0
голосов
1ответ
106 показов
Как организовать рассылку нескольких тысяч http запросов каждые N секунд в .NET Core?
Моя система должна будет каждые, например, 60 секунд отправлять много http запросов. Это рассылка пуш уведомлений с помощью FCM Cloud Messaging. Вот документация. Я не особо опытный .NET разработчик. ...
1
голос
1ответ
215 показов
Организовать очередь сообщений
Есть задача организовать систему передачи сообщений от клиента к менеджеру. Сейчас используется со стороны клиента ejabber , со стороны менеджера "своя система приема и отправки сообщений" . Думаю что ...
1
голос
0ответов
48 показов
Персистентные очереди - это одно и тоже, что и устойчивые очереди?
Персистентные очереди - это одно и тоже, что и устойчивые очереди?
Правильно ли понимаю, что это просто способность очереди сохранять сообщения при аварийном завершении или перезагрузке сервера?
1
голос
1ответ
181 показ
Вопрос по работе с раббитом. pika.exceptions.ConnectionWrongStateError: Illegal close(320, "Timeout while setting up AMQP
Есть задача, асинхронно закинуть сообщения в очередь раббита. Делаю я это следующим образом:
import pika
import datetime
import traceback
import asyncio
import argparse
import os
import jsonschema
...
0
голосов
0ответов
144 показа
Celery получает task но не выполняет
Проект был на python 3.6, переведя на 3.7 слетел celery. При запуске, task получают но не выполняют.
python3.7 + celery 3.1.25
в терминале:
Received task: app.tasks.send_mail[6aafc459-acd7-463e-bb72-...
1
голос
0ответов
19 показов
Общая очередь для микросервисов в RabbitMQ через EasyNEtQ
Проблема в следующем: настроил AutoSubscriber. Отправляют сообщения через Bus.PublishAsync. Сообщения по типу WebApplication1.Event.UserCreatedEvent, WebApplication1 попадают в очередь с таким же ...
0
голосов
1ответ
350 показов
Неверно задано имя папки. Синтаксическая ошибка в имени файла, имени папки или метке тома. Ошибка при запуске RabbitMQ
Попытался настроить RabbitMQ пару дней назад. Следовал инструкциям с сайта: https://thewebland.net/development/devops/ustanovka-rabbitmq-na-windows/. Вроде как всё работало и я сделал всё как хотел. ...
0
голосов
1ответ
70 показов
Не перенаправляется вывод из cmd в файл
Приветсвую, всех) Моя программа из двух файлов: emit_log.py - отправитель сообщений и приёмник - receive_logs.py. Если запустить приёмник в консоли (python receive_logs.py), то всё сообщения ...
0
голосов
0ответов
551 показ
pika.exceptions.AMQPConnectionError при подключении к localhost
кто наткнулся на мой вопрос. Я только начал изучать библиотеку pika в Python для работы с очередями в RabbitMQ. И вот первый же код вызывает исключение:
import pika
connection = pika....