網上不少寫法都是 type='fanout'
這樣的。(這裏是基於python=3.6版本, pika=0.13.0 版本)python
credentials = pika.PlainCredentials('guest', 'guest') connection = pika.BlockingConnection(pika.ConnectionParameters('127.0.0.1',5672,'/',credentials)) channel = connection.channel() # 定義交換機,exchange表示交換機名稱,type表示類型 channel.exchange_declare(exchange='logs_fanout', type='fanout')
拋出異常code
channel.exchange_declare(exchange='logs_fanout', type='fanout') TypeError: exchange_declare() got an unexpected keyword argument 'type'
應該把:type='fanout'
改爲 change_type='fanout'
io
channel.exchange_declare(exchange='logs_fanout', exchange_type='fanout')