flask - 将 Flask 与 Faust 集成

Question

我正在尝试让一个浮士德代理在 flask View /端点内转换消息，
我找不到任何例子，我真的很挣扎。

有没有人成功尝试过这个？
文档说使用 gevent 或 eventlet 作为 asyncio 的桥梁，但不明白多么不幸

Answer 1

你可以试试monkeypatch带有 gevent 或 eventlet 的 flask 应用程序。据我所知，eventlet 是自网桥 aiogevent 以来唯一正在工作的在 pip 中不再可用。

另一种方法是委托(delegate)您的 Flask 应用程序只生成带有 pykafka 的消息。或 kafka-python .通过这种方式，您将保持两个应用程序隔离， flask 生产和浮士德消费。请注意，默认情况下，faust 将尝试创建没有 internal 的主题。带有 1 个副本的标志和带有 8 个副本的内部主题。