pika

5Ciepło

1Odpowiedz

pika.exceptions.ProbableAuthenticationError podczas próby wysłania wiadomości do kolejki zdalnej

Próbuję uruchomić RabbitMQ Python tutorial, ale z nadawcą na maszynie host i odbiorniku maszyny wirtualnej oraz w kolejce na komputerze gościa Virtualbox. Więc zmodyfikowałem wspomniany kod send.py, z

python rabbitmq pika 2015-05-13

---

14Ciepło

2Odpowiedz

SparkStreaming, RabbitMQ i MQTT w Pythonie za pomocą pika

Po to, aby wszystko było trudne, chciałbym spożywać wiadomości z kolejki rabbitMQ. Teraz wiem, że istnieje wtyczka do MQTT na królika (https://www.rabbitmq.com/mqtt.html). Jednak nie mogę zrobić przyk

python apache-spark rabbitmq mqtt pika 2016-06-16

---

6Ciepło

1Odpowiedz

pika, stop_consuming nie działa

Jestem nowy dla rabbitmq i pika i mam problem z zatrzymaniem konsumpcji. kanał kolejek ustawienie: connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.ch

python rabbitmq pika 2014-12-23

---

5Ciepło

2Odpowiedz

Python and RabbitMQ - Najlepszy sposób na słuchanie zdarzeń na różnych kanałach?

Mam dwie oddzielne instancje RabbitMQ. Próbuję znaleźć najlepszy sposób na słuchanie wydarzeń z obu. Na przykład, mogę spożywać zdarzeń na jednym z następujących: credentials = pika.PlainCredentials(u

python rabbitmq pika 2015-02-16

---

7Ciepło

1Odpowiedz

RabbitMQ zamyka połączenie podczas przetwarzania długich zadań, a ustawienia limitu czasu powodują błędy.

Używam producenta RabbitMQ do wysyłania długotrwałych zadań (30 minut +) do klienta. Problem polega na tym, że konsument wciąż pracuje nad zadaniem, gdy połączenie z serwerem zostanie zamknięte, a żąd

python rabbitmq amqp pika python-pika 2016-03-21

---

14Ciepło

5Odpowiedz

błąd „nieznany znacznik dostawy” występuje wtedy, gdy próbuję wiadomości ACK do RabbitMQ użyciu Pika (Python)

Chcę wiadomości procesowe w kilku wątkach ale dostaję błąd podczas wykonywania tego kodu: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import

python message-queue rabbitmq pika 2012-02-22

---

5Ciepło

1Odpowiedz

Jak komunikować się z RabbitMQ (biblioteka Pika) w aplikacji tornado

Adapterem Tornado obsługującym bibliotekę Pika, here jest przykładowy sposób publikowania wiadomości za pomocą adaptera asynchronicznego. Chcę użyć pika w aplikacji tornado, tylko przykład, chcę umieś

python rabbitmq tornado amqp pika 2013-07-09

---

12Ciepło

1Odpowiedz

Strategia RabbitMQ, Pika i ponowne połączenie

Używam Pika do przetwarzania danych z RabbitMQ. Jak mi się zdawało, że natrafiłem na różne problemy, postanowiłem napisać małą aplikację testową, aby zobaczyć, jak poradzę sobie z rozłączeniami. Napis

python rabbitmq pika 2012-02-29

---

21Ciepło

1Odpowiedz

Która forma połączenia z pika

Próbuję dowiedzieć się, która forma połączenia powinien być używany podczas korzystania z pika, mam dwie alternatywy, o ile rozumiem. Albo BlockingConnection lub SelectConnection, jednak nie jestem pe

python rabbitmq pika 2012-08-16

---

7Ciepło

1Odpowiedz

Zużycie synchroniczne i blokujące w RabbitMQ przy użyciu pika

Chcę pobierać kolejkę (RabbitMQ) synchronicznie z blokowaniem. Uwaga: poniżej jest pełny kod gotowy do uruchomienia. System skonfigurował system RabbitMQ jako system kolejkowania, ale w jednym z naszy

python python-2.7 rabbitmq pika 2014-10-21

---