文件名称：twitter-stream-engine:Twitter Streaming API记录器
文件大小：20KB
文件格式：ZIP
更新时间：2024-04-04 17:22:50
Python
Twitter流记录器 目标 连接到 筛选讯息 跟踪应用程序多次运行中每秒的消息统计信息 建筑学 该项目是使用。 使用HTTP（和REST）是很常见的，但是正如我们将看到的，我们可以使用其他类型的通信协议，例如基于AMQP（高级消息队列协议）的RPC（远程过程调用）。 为此，我们将使用Python微服务框架 。 它内置RPC over AMQP，使您可以轻松地在服务之间进行通信。 它还具有用于HTTP查询的简单界面，为简单起见，我们将在本项目中使用该界面。 但是，要编写公开HTTP端点的微服务，建议您使用其他框架，例如或 。 要使用Flask通过RPC调用Nameko方法，可以使用 ，该包装器是为将Flask与Nameko互操作而构建的。 Nameko还允许非常轻松地扩展服务。 Nameko的构建是为了可靠地处理集群中的方法调用。 考虑到向后兼容性，构建服务很重要，因为在生产环境中
【文件预览】：
twitter-stream-engine-main
----gateway()
--------gateway()
--------Dockerfile(270B)
--------run.sh(281B)
--------requirements.txt(108B)
--------config.yml(109B)
----logger()
--------logger()
--------Dockerfile(268B)
--------run.sh(280B)
--------requirements.txt(88B)
--------config.yml(109B)
--------test()
----listener()
--------Dockerfile(272B)
--------run.sh(282B)
--------requirements.txt(126B)
--------config.yml(265B)
--------test()
--------listener()
----README.md(4KB)
----Makefile(663B)
----statistics()
--------Dockerfile(276B)
--------run.sh(388B)
--------requirements.txt(101B)
--------config.yml(216B)
--------test()
--------statistics()
----docker-compose.yml(2KB)
----.gitignore(79B)
----.coveragerc(168B)