Eventlet 在 queue.put 断言异常

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

希望对大家有所帮助。