kombu

3熱度

1回答

架構考慮一個帶有DB記錄的系統。每條記錄可以是live或expired狀態;應使用外部軟件模塊定期處理live記錄。我已經用Kombu和RabbitMQ的經典生產者 - 消費者體系結構解決了這個問題。生產者每隔幾秒從DB獲取記錄，並由消費者處理它們。問題的live事件的數量差別很大，並在高峯時段，消費者不能處理負載和隊列堵塞物品萬人。我想使系統具有適應性，以便生產者在隊列爲空時不會向消費

1熱度

1回答

海帶 - 類型錯誤：結構（）參數1必須是字符串，而不是UNICODE

我一直在使用Kombu了一段時間了 - 而今天，當我準備好一臺新機器進行部署，我就import得到TypeError從kombu： >>> import kombu >>> from kombu import Connection, Exchange, Queue, Producer Traceback (most recent call last): File "<stdin>",

-1熱度

2回答

獲取導入錯誤：無法導入名稱OrderedDict

我收到錯誤 ImportError: cannot import name OrderedDict ，而我的Ubuntu 14.04機器上安裝本地的服務器。我曾嘗試手動安裝ordereddict也試圖提升海帶但它仍然給如下─ [email protected]:~/open-event-orga-server$ sudo python create_db.py Traceback (most r

0熱度

1回答

ImportError：無法導入名稱OrderedDict;降級kombu

我想安裝並導入pytplot，這是一個可以使用python繪製IDL保存文件的包。我在Windows 10上安裝了Python 2.7。如果我嘗試導入pytplot，我得到一個導入錯誤：ImportError：無法導入名稱OrderedDict。這個問題已經在這裏回答了：Getting ImportError: cannot import name OrderedDict。但是，我無法弄清楚如何

0熱度

1回答

無法從Python連接到RabbitMQ

我正在學習Python，並遇到奇怪的問題。我在我的macOS Sierra本地盒子上運行RabitMQ。從python腳本連接到RabbitMQ服務器總是失敗，併發生套接字超時錯誤。同時我可以通過telnet連接。運行的Python 2.7和庫海帶： # test.py from kombu import Connection connection = Connection('amqp:/

3熱度

1回答

氣流運行從UI，KeyError異常任務：沒有這樣的運輸

與芹菜氣流CFG設置爲： broker_url = 'amqp://guest:[email protected]_server:8080' celery_result_backend = db+postgresql://developer:[email protected]_server:5432/db_name 的airflow webserver運行正常，但在運行從氣流UI任務我得到

0熱度

1回答

如何正確使用內存中的傳輸進行單元測試

我想寫一些測試，其中我產生一個消息到一個隊列，看看消息是否得到正確使用和應用程序處理。爲此，我正在玩kombu庫，特別是內存中的Transport實現。仍然我無法得到它的工作，生產的消息被消耗。因此我的問題是，如果有人能提供生產和內存消耗的消息簡單的單元測試

3熱度

1回答

在pytest中模擬一個連接類

我有一個繼承kombu.ConsumerProducerMixin的類，我希望在沒有運行實際的rabbitmq服務的情況下進行測試。 class Aggregator(ConsumerProducerMixin): def __init__(self, broker_url): exchange_name = 'chargers' self.status = 0

0熱度

1回答

從kombu安裝（u'json'，）沒有編碼器

我想我錯過了某個步驟，但我一直在找，並找不到它。當我運行我的芹菜任務時，當我撥打get_task.delay(args)時，我得到此錯誤消息no encoder installed for (u'json',)。我想我有自己的自定義序列化？ settings.py CELERY_ACCEPT_CONTENT = ['pickle'] CELERY_TASK_SERIALIZER = 'json'

0熱度

1回答

Heroku：dbm.error：db類型是dbm.gnu，但該模塊不可用

如何修復下面的錯誤？看起來它必須由Heroku安裝。我是否必須發送電子郵件到heroku進行安裝？或者沒有辦法做到這一點？ 2017-03-26T13:04:08.185159+00:00 heroku[beat.1]: Starting process with command `celery -A PROJECT beat -l info` 2017-03-26T13:04:08.85543