消息海帶 - 類型錯誤「海峽」對象不是可調用

Question

編碼我的消息有效載荷JSON後，我試圖發佈到與經紀人：

connection = establish_connection() 
producer = Producer(channel=connection, 
         exchange="inbound", 
         routing_key="apisubmit") 

producer.publish(body=pl,headers={"api_access_key": "xxxx", "client_id": 4, "object_type": "location", "action": "c"}) 

Django是返回以下：

Traceback: 
File "/usr/local/pythonenv/openblock/lib/python2.6/site-packages/Django-1.3.1-py2.6.egg/django/core/handlers/base.py" in get_response 
    111.       response = callback(request, *callback_args, **callback_kwargs) 
File "/usr/local/pythonenv/openblock/src/myblock/myblock/barz/views.py" in testtwo 
    19.  msg=publish_kombu() 
File "/usr/local/pythonenv/openblock/src/myblock/myblock/barz/messaging.py" in publish_kombu 
    99.       routing_key="apisubmit") 
File "/usr/local/lib/python2.6/dist-packages/kombu/messaging.py" in __init__ 
    82.   self.exchange = self.exchange(self.channel) 

Exception Type: TypeError at /barz/publish_kombu/ 
Exception Value: 'str' object is not callable 

Answer 1

Producer.exchange必須是Exchange。默認情況下它是Exchange("")，不知何故，你必須將它設置爲一個字符串。

Answer 2

如果您將值傳遞給'exchange'參數，它必須是Exchange對象。

您的代碼必須是：

exchange = Exchange(name='inbound') # the minimal declaration 
connection = establish_connection() 
producer = Producer(channel=connection, 
         exchange=exchange, 
         routing_key="apisubmit") 

producer.publish(body=pl,headers={"api_access_key": "xxxx", "client_id": 4, "object_type": "location", "action": "c"}) 

對於Exchange PARAM的完整列表 - docs。

---

我遇到了同樣的錯誤，在隊列聲明即

queue = Queue(name=queue_name, exchange='host_tasks', routing_key=binding_key) 
bound_queue = queue(channel) # only once bound, we can call declare(), purge(), delete() on exchange 

因此聲明的交易所，例如thah

exchange = Exchange('host_tasks', 'direct', durable=True) 
queue = Queue(name=queue_name, exchange=exchange, routing_key=binding_key) 
bound_queue = queue(channel) 

不要忘了import Exchange