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() 

希望这将帮助任何人。