问题描述
我想将我的 2.7 python 项目中的 pika 从 0.9.14
更新为 1.1.0
。所以,现在我尝试连接 TCP,使用 pika 1.1.0
和 twisted 11.0.0
。像这样:
import pika
from pika.adapters import twisted_connection
from twisted.internet import defer,reactor,protocol,task
. . .
credentials = pika.credentials.PlainCredentials(
username=self.system_config.username,password=self.system_config.password)
parameters = pika.ConnectionParameters(
host=self.system_config.host,credentials=credentials,port=self.system_config.port)
client_creator = protocol.ClientCreator(
reactor,twisted_connection.TwistedProtocolConnection,parameters)
self._connection = client_creator.connectTCP(
host=self.system_config.host,port=self.system_config.port,timeout=5)
在这种情况下,self._connection
对象是 None
。如果我尝试使用 pika 版本 0.9.14 执行此操作,则此对象中将是这样的对象 <pika.adapters.twisted_connection.TwistedProtocolConnection object at 0x7f90bbbf51d0>
我做错了什么?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)