0
ответов
Временная очередь, созданная в Celery
Я использую Celery с RabbitMQ . В последнее время я заметил, что создается большое количество временных очередей. Итак, я экспериментировал и обнаружил, что когда задача не выполняется (то есть задача вызывает ...
вопрос задан: 22 August 2011 06:54
0
ответов
Способ разрыва соединения с rabbitmq
У меня есть приложение, в котором есть несколько ошибок. По какой-то причине создаются 2 потребителя, тогда как должен быть только один - и один из них больше не проверяется на наличие сообщений. Я могу обнаружить эту ситуацию ...
вопрос задан: 18 August 2011 23:35
0
ответов
Переключение с ActiveMQ на RabbitMQ
В настоящее время я использую ActiveMQ для обмена сообщениями; за исключением нескольких сбоев БД, он работал хорошо. Однако я, по крайней мере, подумываю попробовать RabbitMQ. Но прежде чем я это сделаю, я хотел бы ...
вопрос задан: 15 August 2011 14:54
0
ответов
Как мне восстановить неподтвержденные сообщения AMQP из каналов, отличных от канала моего соединения?
Кажется, чем дольше я держу сервер rabbitmq в рабочем состоянии, тем больше у меня проблем с неподтвержденными сообщениями. Я бы с удовольствием запросил их. На самом деле, похоже, для этого существует команда amqp, но она ...
вопрос задан: 15 August 2011 09:01
0
ответов
Взаимодействие с Django / Celery из Java
У нашей компании есть веб-сайт на основе Python и несколько рабочих узлов на основе Python, которые взаимодействуют через Django / Celery и RabbitMQ. У меня есть приложение на основе Java, которое должно отправлять задачи в Celery ...
вопрос задан: 3 August 2011 22:00
0
ответов
Чтение из нескольких очередей, RabbitMQ
Я новичок в RabbitMQ. Я хочу иметь возможность обрабатывать сообщения чтения без блокировки, когда есть несколько очередей (для чтения). Любые данные о том, как я могу это сделать? // Редактировать 1 открытый класс Rabbit: ...
вопрос задан: 20 July 2011 15:10
0
ответов
Python: OpenMPI Vs. RabbitMQ
Предположим, что кто-то хочет написать приложение на Python, в котором должна быть связь между различными процессами. Связь будет осуществляться путем отправки строк и / или массивов numpy. Что такое ...
вопрос задан: 20 July 2011 04:48
0
ответов
Как лучше всего безопасно завершить Java-приложение с запущенными потребителями RabbitMQ
У нас есть автономное Java-приложение, выполняющее некоторую фоновую обработку на машине Debian. Задания, которые он должен обрабатывать, отправляются через сообщения RabbitMQ. Когда java-приложение должно быть ...
вопрос задан: 14 July 2011 20:43
0
ответов
RabbitMQ против Socket.io?
Я занимаюсь разработкой веб-приложений в реальном времени. Пользователи браузера должны иметь возможность общаться друг с другом через сервер node.js. Один из пользователей пишет сообщение, и все остальные пользователи его получат. Я ...
вопрос задан: 9 July 2011 10:20
0
ответов
Использование эксклюзивных + постоянных очередей для RabbitMQ
Если я создал эксклюзивную и долговечную очередь ( не автоудаление). Теперь, если потребитель подписывается на эту очередь, а затем она отключается. Затем эта очередь удаляется. Я проверил ...
вопрос задан: 6 July 2011 13:57
0
ответов
Как гарантировать доставку сообщений с помощью Celery?
У меня есть приложение на Python, в котором я хочу начать выполнять больше работы в фоновом режиме, чтобы оно лучше масштабировалось по мере увеличения загруженности. Раньше я использовал Celery для выполнения обычных фоновых задач ...
вопрос задан: 5 July 2011 01:14
0
ответов
PubSub + Надежная доставка сообщений ненадежным подписчикам
Мне нужно создать систему, использующую шину публикации / подписки (например, Mule, ZeroMQ, RabbitMQ), но вся литература подразумевает, что абонентские приложения надежно доступны для получения сообщений от ...
вопрос задан: 28 June 2011 14:21
0
ответов
Работа с дублированием в очереди сообщений
Я спорил со своим программистом о том, как лучше это сделать. У нас есть данные, которые поступают со скоростью около 10000 объектов в секунду. Это нужно обрабатывать асинхронно, но ...
вопрос задан: 28 June 2011 12:44
0
ответов
Использование очереди сообщений rabbitmq с несколькими потоками (Python Kombu)
У меня есть один обмен RabbitMQ с единственной очередью. Я хочу создать демона, который запускает несколько потоков и работает через эту очередь как можно быстрее. «Работа» включает в себя общение ...
вопрос задан: 28 June 2011 08:56
0
ответов
Учебные пособия и документация по «очередям»?
Я ищу статьи и ссылки, дающие обзор «очередей» (я, вероятно, даже не использую здесь правильный термин). Я надеюсь на вводное руководство по миру Redis, ...
вопрос задан: 24 June 2011 08:47
0
ответов
Почему нам нужно использовать rabbitmq
Зачем нам нужен RabbitMQ, когда у нас есть более мощный сетевой фреймворк на Python под названием Twisted. Я пытаюсь понять причину, по которой кто-то захочет использовать RabbitMQ. Не могли бы вы предоставить ...
вопрос задан: 20 June 2011 02:29
0
ответов
RabbitMQ использование немедленного и обязательного bits
Я использовал сервер RabbitMQ, и для публикации сообщений, когда для поля немедленного действия было установлено значение true, я попытался отправить 50 000 сообщений и, используя rabbitmqctl list_queues, я увидел это количество сообщений в ...
вопрос задан: 17 June 2011 02:45
0
ответов
RabbitMQ на EC2, потребляющем тонны ЦП
Я пытаюсь заставить RabbitMQ с Celery и Django работать с экземпляром EC2 для выполнения довольно простой фоновой обработки. Я запускаю rabbitmq-server 2.5.0 на большом экземпляре EC2. Я загрузил и ...
вопрос задан: 15 June 2011 21:21
0
ответов
Что означает nowait в exchange.declare () RabbitMQ?
Довольно простой вопрос . Я не могу найти его в документации или спецификации.
вопрос задан: 15 June 2011 00:34
0
ответов
лучший способ ротации файлов журналов rabbitmq
Мои журналы кроликов становятся очень большими, и мне интересно, есть ли лучший способ контролировать вращение. Я бы хотел, чтобы журналы чередовались в зависимости от размера и сохраняли не более десяти журналов за раз. Лучший я '...
вопрос задан: 13 June 2011 17:04
0
ответов
Как я могу заставить Pika повторить попытку подключения к RabbitMQ, если он терпит неудачу в первый раз?
Я пытаюсь заставить мою программу, которая использует Pika, постоянно повторять попытки подключения к RabbitMQ на неудача. Судя по тому, что я видел в документации Pika, можно использовать класс SimpleReconnectionStrategy ...
вопрос задан: 31 May 2011 04:51
0
ответов
Использование обмена сообщениями, например RabbitMQ, в веб-приложении?
Я хотел бы узнать, каковы сценарии / варианты использования / где обмен сообщениями как RabbitMQ может помочь потребительским веб-приложениям. Есть ли какие-то конкретные ресурсы, на которых можно поучиться? Какие веб-приложения ...
вопрос задан: 31 May 2011 04:38
0
ответов
Новичок в приложениях реального времени - Node.JS + Redis или RabbitMQ -> клиент / сервер как?
Я новичок в разработке приложений в реальном времени и пытаюсь осмыслить бесчисленное множество вариантов. Я прочитал столько сообщений в блогах, заметок и эссе, что люди были ...
вопрос задан: 29 May 2011 18:46
0
ответов
Альтернативы RabbitMQ для .NET-ориентированного магазина?
Мне нужно надежное решение для обмена сообщениями. Похоже, что RabbitMQ удовлетворит потребности моего приложения. Однако моя среда не очень подходит для развертывания Erlang и Mnesia на сервере. Это ...
вопрос задан: 10 May 2011 12:54
0
ответов
Получение результата длительной задачи с RabbitMQ
У меня есть сценарий, в котором клиент отправляет HTTP-запрос для загрузки файла. Файл должен создаваться динамически и обычно занимает 5-15 секунд. Поэтому я ищу решение, которое ...
вопрос задан: 3 May 2011 13:52
0
ответов
RabbitMQ channel creation guidelines
I'm writing a simple class that my apps will use to send and receive messages using RabbitMQ.
I've read as many How-Tos, blog posts, white papers and the likes about RabbitMQ as I could find.
most of ...
вопрос задан: 15 April 2011 18:54
0
ответов
How do you process messages in parallel while ensuring FIFO per entity?
Let's say you have an entity, say, "Person" in your system and you want to process events that modify various Person entities. It is important that: Events for the same Person are processed in FIFO ...
вопрос задан: 15 April 2011 17:50
0
ответов
Использование сельдерея в качестве отказоустойчивого планировщика
я хотел бы использовать celery w / rabbitmq как отказоустойчивый планировщик в распределенной среде.
Под отказоустойчивым я подразумеваю, что если задача передана работнику, и этот работник отключается из-за чего-то ...
вопрос задан: 6 April 2011 08:58
0
ответов
Rabbitmq - множественная привязка (ключи маршрутизации) к одной очереди
Мне нужна ссылка на очередь с привязкой нескольких ключей маршрутизации.
Видите ли, я создал очередь и связал ее один раз с помощью channel.queuebind (), а другой раз - еще раз с каналом ....
вопрос задан: 31 March 2011 10:24
0
ответов
Проблема с установкой RabbitMQ на Centos 5.5
Я пытался запустить rabbitmq-server-2.4.0 на Centos
5.5 на инстансе Amazon AWS. В моем экземпляре используется следующее ядро: 2.6.18-xenU-ec2-v1.2 Я пробовал установить erlang ...
вопрос задан: 28 March 2011 18:39