消息海带 - 类型错误“海峡”对象不是可调用

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