python - Flask - 拉取实时流 kafka 数据 - 将 Kafka 与 Python Flask 集成

标签 python flask socket.io flask-socketio kafka-python

此项目用于实时搜索引擎 - 日志分析性能。

我有一个从 Spark 处理到 Kafka 的实时流数据。

现在有了 Kafka 输出, 我想使用 Flask 从 Kafka 获取数据.. 并使用 Chartjs 对其进行可视化 或其他一些可视化..

如何使用 python flask 从 Kafka 获取实时流数据

知道我该如何开始吗?

任何帮助将不胜感激!

谢谢!

最佳答案

我会检查 python 的 Kafka 包:

http://kafka-python.readthedocs.org/en/master/usage.html

这应该让您设置为从 Kafka 流式传输数据。此外,我可能会检查这个项目:https://github.com/travel-intelligence/flasfka这与一起使用 Flask 和 Kafka 有关(刚刚在谷歌搜索中找到它)。

关于python - Flask - 拉取实时流 kafka 数据 - 将 Kafka 与 Python Flask 集成,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35218578/

相关文章:

python - 处理超过最大递归深度

python - 如何检查 Django Queryset 是否返回多个对象?

azure应用程序服务中的Python ModuleNotFoundError包

python - Flask-Migrate "No section: ' alembic '"on "db migrate”命令

node.js - 简单的 nodeJS 示例不适用于 socket.io

javascript - 客户端能否知道 Node.js 服务器已断开他的连接

python - 确定 ‘data’ 的平均值,其中 CONTINUOUS cond=True 的最高数量

python - 模板不显示图像

python - 为什么 Flask 不使用我自定义的 json_encoder?

javascript - 如何将 socket.io(在 nodejs 中)的事件处理程序绑定(bind)到我自己的范围?