【文件属性】：
文件名称：mq-to-db:从消息队列系统中读取特定的有效负载消息并将其存储到数据库系统中
文件大小：115KB
文件格式：ZIP
更新时间：2021-04-18 01:15:43
rabbitmq storage concurrency consumers prometheus-metrics
mq-to-db（消息队列到数据库）
这是一个程序，用于从消息队列系统中读取并使用并发存储到数据库中
这是其工作原理的特写图像：
消费者支持
支持存储
特征
队列使用者的数量可能与存储工作者的数量不同，请参阅
从队列使用一条消息并将其存储到数据库中的过程（作业）是同步的，因为需要确认（确认为已存储）每条消息。
Golang pprof通过启用--profile启动服务时命令行
面向消费者，存储工作者，go统计信息和数据库的Prometheus指标
用于Prometheus.io指标的Grafana仪表板
Dockerfile多阶段构建
Makefile，以方便项目构建
docker-compose文件和配置以测试所有元素
docker -hub和Github软件包中的docker映像
CI / CD Github Action管道工作流程
如何执行
有很多方法可以做到这一点，但是对
【文件预览】：
mq-to-db-master
----.gitignore(283B)
----go.mod(383B)
----Dockerfile(1KB)
----images()
--------nxconsumers-mxworkers.jpg(53KB)
----Makefile(4KB)
----config-sample.yaml(901B)
----LICENSE(11KB)
----CHANGELOG.md(463B)
----go.sum(53KB)
----.github()
--------workflows()
----docker-compose.yaml(3KB)
----README.md(7KB)
----docker-compose()
--------prometheus()
--------mq-to-db()
--------grafana()
----.golangci.yml(448B)
----docs()
--------messages.md(463B)
--------config.md(2KB)
--------references.md(6KB)
----cmd()
--------mq-to-db()
----internal()
--------version()
--------storer()
--------storage()
--------config()
--------messages()
--------logger()
--------consumer()
--------metrics()