pika - python rabbitMQ flush_output错误
黄舟
黄舟 2017-04-18 09:45:56
0
1
538

程序:

while(1):
    # query tasks from local file
    if task:
        publish(video_id)
    else:
        sleep(1)

长时间运行后,会报出以下错误,这是啥意思?

Traceback (most recent call last):
  File "publisher_dev.py", line 209, in <module>
    publish(video_id)
  File "publisher_dev.py", line 157, in publish
    delivery_mode=2,  # make message persistent
  File "/home/weike/.local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 1978, in basic_publish
    mandatory, immediate)
  File "/home/weike/.local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 2065, in publish
    self._flush_output()
  File "/home/weike/.local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 1174, in _flush_output
    *waiters)
  File "/home/weike/.local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 395, in _flush_output
    raise exceptions.ConnectionClosed()
pika.exceptions.ConnectionClosed
黄舟
黄舟

人生最曼妙的风景,竟是内心的淡定与从容!

membalas semua(1)
左手右手慢动作

Sambungan antara klien dan pelayan telah tamat masa Anda perlu menggunakan connection.sleep() dan bukannya time.sleep()

Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan
Tentang kita Penafian Sitemap
Laman web PHP Cina:Latihan PHP dalam talian kebajikan awam,Bantu pelajar PHP berkembang dengan cepat!