Eventlet在隊列上聲明異常。輸入

Question

我在嘗試將eventlet/queue放入某​​個項目時不時發現奇怪的異常。

for message in kafka_consumer: 
    queue_in.put(message.value) 

packages/eventlet/queue.py", line 265, in put 
    assert result is waiter, "Invalid switch into Queue.put: %r" % (result,) 
AssertionError: Invalid switch into Queue.put: ([16], [], []) 

任何想法可能是什麼原因呢？

謝謝。

Answer 1

我發現這個問題的解決是加入後eventlet.sleep（）：

queue.put(event) 
eventlet.sleep() 

希望這將幫助任何人。