Описание тега kombu
Kombu - это среда обмена сообщениями AMQP для Python.
1
ответ
Соединения RabbitMQ не закрываются автоматически при остановке или остановке экземпляров EC2
Я использую python Kombu (3.0.26) с разъемом librabbitmq для подключения к rabbitmq в AWS на экземпляре EC2. Когда я запускаю и останавливаю приложение, соединение с кроликом приходит и уходит, как и ожидалось. Когда я убиваю приложение с помощью TE…
18 авг '15 в 01:05
0
ответов
Комбу "медленный" с транспортом в памяти
Я пытаюсь использовать комбу, чтобы ослабить какую-то часть моего программного обеспечения. Так как мне не нужны ни постоянство, ни межпроцессное взаимодействие, я бы не хотел использовать некоторый внешний демон, поэтому я попробовал транспорт в па…
20 авг '15 в 15:14
0
ответов
Хочешь сделать потребителя, не уверен, достаточно ли комбу или мне нужно также внедрить сельдерей
Я нахожусь в процессе создания потребителя для rabbtMQ. Я использую Python и после исследования я решил использовать Kombu. С Комбу я уже подключился к очереди в кролике и прочитал сообщения. Код queue = Queue('someQueue') def process(body, message)…
14 апр '15 в 16:58
3
ответа
Производитель комбу и потребитель сельдерея
Может ли производитель комбу поставить в очередь сообщение на rabbitmq для обработки сельдереями? Похоже, что работники сельдерея не понимают послания производителя комбу.
13 апр '15 в 16:53
1
ответ
Цветок сельдерея может остановить работника, но не может его перезапустить
Я установил Сельдерей, Джанго-Сельдерей, Комбу и Флауэр. Цветок сельдерея в порядке. Он может завершить работу рабочих, но не может их перезапустить. Цветочные ответы: [I 140903 15:49:12 web:1856] 200 GET / (127.0.0.1) 77.49ms [I 140903 15:49:13 web…
03 сен '14 в 12:34
0
ответов
Как использовать Gevent с Kombu
Я пишу основной скрипт публикации-подписки на python, используя kombu и rabbitmq вместе с gevent. Как мы можем переключить контекст на издателя, когда потребитель ожидает в очереди, пока не прибудет сообщение? Я пытался использовать gevent.sleep(), …
01 июн '17 в 19:08
1
ответ
Django & Celery - проблемы с маршрутизацией
Я использую Django и Celery и пытаюсь настроить маршрутизацию к нескольким очередям. Когда я указываю задачи routing_key а также exchange (либо в декораторе задачи, либо используя apply_async()), задача не добавляется в брокер (это Kombu, подключающ…
22 май '12 в 17:49
0
ответов
Применение сельдерея без сериализации вообще
Мое приложение Django вообще не нуждается в сериализации. Данные, передаваемые между приложением и рабочим, состоят исключительно из строк ascii. Конечно, сериализация по умолчанию работает и json не трогает их, но я бы хотел полностью ее отключить.…
03 мар '18 в 23:53
0
ответов
Интеграция zmq в приложение flask-socketio как (комбу) транспорт message_queue
Я работаю над приложением Flask-SocketIO, которое интегрируется с zmq. Основная предпосылка приложения заключается в том, что веб-сервер Flask-SocketIO получает сообщение zmq, а затем сообщение zmq преобразуется в сообщение SocketIO, которое отправл…
21 ноя '16 в 14:33
1
ответ
Могу ли я получить идентификатор подключения RabbitMq от моего клиента Python/ Kombu?
Когда я запускаю эту команду: rabbitmqctl list_connections pid Я получаю вывод, как показано ниже: <rabbit@my_box.2.1234.0> <rabbit@my_box.2.1235.0> Есть ли способ прочитать этот pid с моего клиента Kombu?
17 мар '16 в 13:42
0
ответов
Управляющий хэш-код python (#)
Получил приложение на Python с использованием сельдерея, настроенного с помощью бэкэнда Redis, и использую Supervisor для запуска сервисов. Проблема в том, что мой пароль Redis получил хеш # символ в нем, и как таковой я получаю ошибку, как показано…
06 янв '17 в 07:39
1
ответ
Не установлен кодировщик для (u'json',) из Kombu
Я думаю, что пропускаю шаг где-то, но я искал вокруг и не могу найти его. Когда я запускаю свою задачу сельдерея, я получаю это сообщение об ошибке no encoder installed for (u'json',) когда я звоню get_task.delay(args), Должен ли я иметь свою собств…
06 окт '17 в 12:00
5
ответов
Ошибка рабочего Django / Celery / Kombu: получено и удалено неизвестное сообщение. Неправильный пункт назначения?
Кажется, что сообщения не попадают в очередь должным образом. Я использую Django с Celery и Kombu, чтобы использовать собственную базу данных Django в качестве бэкенда. Все, что мне нужно, это очень простая настройка Pub / Sub. В конечном итоге он б…
14 фев '13 в 22:39
2
ответа
Ошибка импорта Django "нет модуля с именем django"
Когда я пытаюсь запустить приложение django в openshift, я получаю следующее сообщение. Следовательно, развертывание не удается... File "wsgi/djangoProjectNew/manage.py", line 11, in <module> execute_from_command_line(sys.argv) File "/var/lib/…
31 окт '16 в 19:51
2
ответа
Ошибка декодирования Unicode в Celery при попытке прочитать результаты из очереди Redis
Попытка выполнить несколько простых задач через сельдерей. Заголовок рабочего файла выглядит так from celery import Celery, group from time import sleep celery = Celery('workerprocess', broker='redis://localhost:6379/0', backend='redis://localhost:6…
19 янв '19 в 05:32
0
ответов
Окунитесь в `комбу. Потребитель`
Является kombu.Consumer процесс / поток, который на самом деле вызывает __callback__ и выполняет задачу, или это просто родитель, который порождает детей для выполнения задач? Мне нужно загрузить некоторые веса в графический процессор до того, как з…
24 фев '19 в 08:45
0
ответов
Использование Celery/Kombu для обработки простых сообщений JSON в Django
В прошлом я использовал приложения Celery async python и Django, где и отправитель, и получатель понимают задачу, отправляемую в RabbitMQ для обработки через Celery (это может быть одно и то же приложение в кластере и т. Д.). У меня есть пример испо…
12 авг '16 в 14:56
5
ответов
Сельдерей с Amazon SQS
Я хочу использовать Amazon SQS в качестве брокера, поддерживаемого Celery. Существует реализация транспорта SQS для Kombu, от которой зависит Celery. Однако документации для его использования недостаточно, поэтому я не могу найти, как настроить SQS …
08 ноя '11 в 09:53
1
ответ
Ошибка сельдерея "Нет такого транспорта: amqp"
Селери работал нормально, однажды работнику командной строки не удалось запустить следующую трассировку: Traceback (most recent call last): File "/home/buildslave/venv/bin/celery", line 9, in <module> load_entry_point('celery==3.0.7', 'console…
24 авг '12 в 19:44
0
ответов
Не могу ничего импортировать из комбу
Я здесь очень запутался. Я слежу за документами комбу дословно. Я бегу в виртуальной среде. У кого-нибудь была похожая проблема? (pipes)slim-2:consumers ryan$ pip install kombu Downloading/unpacking kombu Downloading kombu-3.0.24-py2.py3-none-any.wh…
11 мар '15 в 16:21