文件名称：kafka-influxdb:InfluxDB的高性能Kafka使用者。 支持收集的消息格式
文件大小：942KB
文件格式：ZIP
更新时间：2024-05-20 07:32:10
performance logstash influxdb consumer kafka-consumer
Kafka-InfluxDB 一个用Python编写的InfluxDB的Kafka使用者。 支持InfluxDB 0.9.x及更高版本。 要获得InfluxDB 0.8.x支持，请签出。 :warning: 该项目应能按预期工作，并且非常欢迎进行错误修复，但是有关新功能的活动很少。 对于较新的项目，我建议改为使用 ，它既更快又更通用。 用例 Kafka将在高负载期间充当指标数据的缓冲区。 对于从离岸数据中心发送不可靠连接到您的监控后端的指标，这也很有用。 快速开始 为了进行快速测试，请在容器内与Kafka和InfluxDB一起运行kafka-influxdb。 一些示例消息会在启动时自动生成（使用kafkacat）。 Python 2： make docker exec -it kafkainfluxdb python -m kafka_influxdb -c config_example.ya
【文件预览】：
kafka-influxdb-master
----MANIFEST.in(55B)
----.dockerignore(16B)
----kafka_influxdb()
--------writer()
--------__init__.py(24B)
--------profile()
--------config()
--------__main__.py(2KB)
--------reader()
--------tests()
--------version.py(22B)
--------encoder()
--------worker.py(5KB)
----docker()
--------logstash()
--------telegraf()
--------common-services.yml(726B)
--------run.sh(693B)
--------pypy()
--------py2()
--------influxdb()
--------kafkacat()
--------py3()
----.github()
--------FUNDING.yml(31B)
----Dockerfile(229B)
----release.py(610B)
----requirements.txt(609B)
----config_example.yaml(505B)
----.travis.yml(1KB)
----pytest.ini(35B)
----LICENSE(11KB)
----assets()
--------benchmark.ods(47KB)
--------release.txt(391B)
--------benchmark.png(199KB)
--------schema.svg(172KB)
--------schema.png(55KB)
--------schema.jpg(28KB)
--------schema-small.png(40KB)
----setup.cfg(109B)
----setup.py(2KB)
----README.md(10KB)
----Makefile(2KB)
----.gitignore(666B)
----CHANGELOG.md(4KB)