python - 如何创建一个烧瓶服务器来生成数据以输入 kafka？
问题描述
我正在尝试创建一个服务器，它从本地机器或 s3 读取大量数据（将是 json 或基于行的），然后将每一行吐出到..某个地方，以便 kafka 可以摄取这些数据. 我怎样才能用烧瓶制作这个服务器并控制它每秒或每分钟输出多少？
解决方案
推荐阅读
- pip - 如何使用需求文件以可编辑模式从本地目录安装相互依赖的包
- javascript - DatePicker 和 Calendar 显示格式 Year+543 为泰国年（佛教年）
- compiler-errors - 无法在 Windows 上编译 Rust hello world：未找到链接器 link.exe
- python - split() 和 replace(' ','') 有什么区别？
- x86 - 为什么 MIPS 中没有 RET 指令，而 x86 有 RET 指令？
- python - 如何从另一个类运行函数并使用其变量？
- node.js - TypeScript 错误：Rxjs 调用 setTimeout 与 @types/node 中定义的不同
- javascript - 使用多边形作为带有传单的标记
- python - 我可以将文件视为python中的列表吗？
- javascript - 离线应用程序中的 Javascript 存储