wdtinc / flask-pika Goto Github PK

app.config['FLASK_PIKA_POOL_PARAMS'] = {
    'pool_size': 16,
    'pool_recycle': 600
}

File "D:\project\controllers\pikatest.py", line 32, in test_place
    ch = pika.channel()
  File "C:\Program Files (x86)\Python36-32\lib\site-packages\flask_pika.py", line 132, in channel
    if self.__should_recycle_channel(ch):
  File "C:\Program Files (x86)\Python36-32\lib\site-packages\flask_pika.py", line 115, in __should_recycle_channel
    recycle_time = self.channel_recycle_times[hash(channel)]
KeyError: 4410099

ch = pika.channel()
ch.basic_publish(exchange='', routing_key='place', body=json.dumps(body))
pika.return_channel(ch)

from flask import Flask
from flask_pika import Pika as FPika

app = Flask(__name__)
app.config['FLASK_PIKA_PARAMS'] = {
    'host':'localhost',      #amqp.server.com
    'port': 5672,            #amqp server port
    'username' : 'guest',
    'password' : 'guest',
    'virtual_host':'vhost'   #amqp vhost
}


app.config['FLASK_PIKA_POOL_PARAMS'] =  {
    'pool_size': 8,
    'pool_recycle': 600
}
fpika = FPika(app)


ch = fpika.channel()
ch.basic_publish(exchange='daemon',routing_key='routing_key',exchange_type = 'fanout')
fpika.return_channel(ch)

if __name__ == "__main__":
    app.run()