Результаты поиска по запросу "rabbitmq"
Также в отношении «Обратите внимание, что фабрика считывателей будет сериализована и отправлена исполнителям, затем будет создан считыватель данных для исполнителей и будет выполняться фактическое чтение». Реализация сокета соблюдает это - просто статическая часть буфера данных сериализуется как часть фабрики и читается.
аюсь написать собственный приемник дляStructured Streaming что будет потреблять сообщения отRabbitMQ. Spark недавно выпущенный [https://databricks.com/blog/2018/02/28/introducing-apache-spark-2-3.html] DataSource V2 API, который кажется очень ...
Измерение времени выполнения задачи сельдерея
Я преобразовал автономную пакетную работу, чтобы использовать сельдерей для отправки работы, которую нужно сделать. Я использую RabbitMQ. Все работает на одной машине, и никакие другие процессы не используют экземпляр RabbitMQ. Мой скрипт просто ...
@JebaseelanRavi, не могли бы вы опубликовать полный трекбек на своего рода пастбине или открыть новый вопрос и вставить его туда? Я никогда не видел эту ошибку раньше :)
ользую scrapy для получения сообщения (url) из RabbitMQ, но когда я использую yield для вызова метода parse, передавая мой url в качестве параметров. Программа не входит в метод обратного вызова. Ниже приведен следующий код моего паук # -*- ...
Если вы пойдете по пути построения Erlang вручную при минимальной установке ОС, вы также можете обнаружить, что вам нужно установить wxGTK & wxGTK-devel, чтобы все тесты были построены и работали правильно.
ался запустить rabbitmq-server-2.4.0 и запустить его на Centos 5.5 на экземпляре Amazon AWS. Мой экземпляр использует следующее ядро: 2.6.18-xenU-ec2-v1.2 Я пробовал установить erlang и rabbitmq-сервер, используя: 1) репозиторий yum 2) прямая ...
Да, но потребителю не нужно ждать блокировки - он может перейти к следующей очереди. Предположительно, ваш протокол очередей также позволит потребителям отказаться от чтения сообщения из очереди, и тогда они смогут проверить блокировку.
тим, в вашей системе есть сущность, скажем «Персона», и вы хотите обрабатывать события, которые изменяют разные сущности Персоны. Важно что: События для одного и того же лица обрабатываются в порядке FIFOНесколько потоков людей обрабатываются ...
Я бы построил ваш синглтон, такой как он имеет шаблон наблюдателя, и содержал бы там все содержимое RabbitMQ со ссылками на ваших абонентов. Затем вам также необходимо выполнить маршаллизацию вызовов для одного потока, который имеет дело с этим, или вы можете рисковать проблемами с объектами канала.
у простой класс, который мои приложения будут использовать для отправки и получения сообщений с использованием RabbitMQ. Я прочитал столько How-Tos, постов в блогах, официальных документов и тому подобного о RabbitMQ, сколько смог найти. В ...
Celery Beat: ограничение до одного экземпляра задачи за раз
У меня есть стебель сельдерея и сельдерей (четыре рабочих), чтобы сделать несколько этапов обработки навалом. Одна из этих задач примерно такая: «для каждого X, для которого не было создано Y, создайте Y». Задача запускается периодически с ...
Как отключить TCP-порт прослушивания RabbitMQ по умолчанию - 5672
Я настроил RabbitMQrabbitmq.config файл с новым номером порта, то есть 5671 с SSL. Теперь я хочу отключить порт по умолчанию, то есть 5672. Файл конфигурации, как показано ниже: - [ {rabbit, [ {ssl_listeners, [5671]}, ...
Этот класс Consumer предоставляет полученное событие, которое вы можете использовать, и поэтому НЕ блокирует. Остальная часть кода в основном остается прежней.
ичок в RabbitMQ. Я хочу иметь возможность обрабатывать чтение сообщений без блокировки, когда есть несколько очередей (для чтения из). Есть какие-то отзывы о том, как я могу это сделать? // Редактировать 1 public class Rabbit : IMessageBus { ...
отлично, спасибо
ли настроитьRabbitMQ сервер наAmazon EC2 instanceи мои машины в офисе подключаются к этомуRabbitMQ сервер и отправлять / получать сообщения на / с него? Я буду обвиненAmazon для пропускной способности / сообщений, которые поступают в / из ...