这是一个基于 mqtt 做的转存项目。 通过 mqtt 的发布订阅模式，从 borker 接收到 topic 信息，解析并处理后，存入 minio、tedengine、kafka 中。 其中 mqtt 消费端，采用多进程+协程的方式异步处理消息，以突破单线程的消费速度瓶颈。 也同时封装了 minio、tedengine、kafka 部分功能的 API 方法，以便清晰明了好用。
这是一个基于 mqtt 做的转存项目。 通过 mqtt 的发布订阅模式，从 borker 接收到 topic 信息，解析并处理后，存入 minio、tedengine、kafka 中。 其中 mqtt 消费端，采用多进程+协程的方式异步处理消息，以突破单线程的消费速度瓶颈。 也同时封装了 minio、tedengine、kafka 部分功能的 API 方法，以便清晰明了好用。
采用 django-channels 来实现 websocket 的消息实时通讯，BeatServer 实现通道层定时任务发送，djangorestframework-simplejwt 生成 token，用于 websocket 的连接认证
封装celery、logging、openpyxl通用方法
最近一年贡献：5 次
最长连续贡献：2 日
最近连续贡献：1 日
贡献度的统计数据包括代码提交、创建任务 / Pull Request、合并 Pull Request，其中代码提交的次数需本地配置的 git 邮箱是 Gitee 帐号已确认绑定的才会被统计。