{ "info": { "author": "Matthias Endler", "author_email": "matthias-endler@gmx.net", "bugtrack_url": null, "classifiers": [ "Development Status :: 4 - Beta", "License :: OSI Approved :: Apache Software License", "Programming Language :: Python", "Programming Language :: Python :: 2", "Programming Language :: Python :: 2.7", "Programming Language :: Python :: 3", "Programming Language :: Python :: 3.3", "Programming Language :: Python :: 3.4", "Programming Language :: Python :: 3.5", "Programming Language :: Python :: 3.6", "Programming Language :: Python :: Implementation :: PyPy", "Topic :: Utilities" ], "description": "Kafka-InfluxDB\n==============\n\n| |Build Status|\n| |Coverage Status|\n| |Code Climate|\n| |PyPi Version|\n| |Scrutinizer|\n\n| A Kafka consumer for InfluxDB written in Python.\n| Supports InfluxDB 0.9.x and up. For InfluxDB 0.8.x support, check out the `0.3.0 tag `__.\n\nUse cases\n---------\n\n| Kafka will serve as a buffer for your metric data during high load.\n| Also it's useful for sending metrics from offshore data centers with unreliable connections to your monitoring backend.\n\n|image5|\n\nQuickstart\n----------\n\nFor a quick test, run kafka-influxdb inside a container alongside Kafka and InfluxDB. Some sample messages are generated automatically on startup (using kafkacat).\n\nPython 2:\n^^^^^^^^^\n\n::\n\n make\n docker exec -it kafkainfluxdb\n python -m kafka_influxdb -c config_example.yaml -s\n\nPython 3:\n^^^^^^^^^\n\n::\n\n make RUNTIME=py3\n docker exec -it kafkainfluxdb\n python -m kafka_influxdb -c config_example.yaml -s\n\nPyPy 5.x\n^^^^^^^^\n\n::\n\n make RUNTIME=pypy\n docker exec -it kafkainfluxdb\n pypy3 -m kafka_influxdb -c config_example.yaml -s --kafka_reader=kafka_influxdb.reader.kafka_python\n\n(Note that one additional flag is given: ``--kafka_reader=kafka_influxdb.reader.kafka_python``. This is because PyPy is incompabile with the confluent kafka consumer which is a C-extension to librdkafka. Therefore we use the kafka\\_python library here, which is compatible with PyPy but a bit slower.)\n\nInstallation\n------------\n\n::\n\n pip install kafka_influxdb\n kafka_influxdb -c config-example.yaml\n\nPerformance\n-----------\n\n| The following graph shows the number of messages/s read from Kafka for various Python versions and Kafka consumer plugins.\n| This is testing against a Kafka topic with 10 partitions and five message brokers.\n| As you can see the best performance is achieved on Python 3 using the ``-O`` flag for bytecode optimization in combination with the ``confluent-kafka`` reader (default setup). Note that encoding and sending the data to InfluxDB might lower this maximum performance although you should still see a significant performance boost compared to logstash.\n\n|Benchmark results|\n\nBenchmark\n---------\n\nFor a quick benchmark, you can start a complete ``kafkacat -> Kafka -> kafka_influxdb -> Influxdb`` setup with the following command:\n\n::\n\n make\n\nThis will immediately start reading messages from Kafka and write them into InfluxDB. To see the output, you can use the InfluxDB cli.\n\n::\n\n docker exec -it docker_influxdb_1 bash # Double check your container name\n influx\n use metrics\n show measurements\n\nSupported formats\n-----------------\n\nYou can write a custom encoder to support any input and output format (even fancy things like Protobuf). Look at the examples inside the ``encoder`` directory to get started. The following formats are officially supported:\n\nInput formats\n^^^^^^^^^^^^^\n\n- `Collectd Graphite ASCII format `__: :\n\n::\n\n mydatacenter.myhost.load.load.shortterm 0.45 1436357630\n\n- `Collectd JSON format `__:\n\n.. code:: json\n\n [{\n \"values\":[\n 0.6\n ],\n \"dstypes\":[\n \"gauge\"\n ],\n \"dsnames\":[\n \"value\"\n ],\n \"time\":1444745144.824,\n \"interval\":10.000,\n \"host\":\"xx.example.internal\",\n \"plugin\":\"cpu\",\n \"plugin_instance\":\"1\",\n \"type\":\"percent\",\n \"type_instance\":\"system\"\n }]\n\n- `Raw InfluxDB line protocol (e.g. for Telegraf support) `__:\n\nOutput formats\n^^^^^^^^^^^^^^\n\n- `InfluxDB 0.9.2+ line protocol format `__: :\n\n::\n\n load_load_shortterm,datacenter=mydatacenter,host=myhost value=\"0.45\" 1436357630\n\n- `InfluxDB 0.8.x JSON format `__ (*deprecated*)\n\nConfiguration\n-------------\n\n| Take a look at the ``config-example.yaml`` to find out how to create a config file.\n| You can overwrite the settings from the commandline. The following parameters are allowed:\n\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| Option | Description |\n+=============================================================+=========================================================================================================+\n| ``-h``, ``--help`` | Show help message and exit |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--kafka_host KAFKA_HOST`` | Hostname or IP of Kafka message broker (default: localhost) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--kafka_port KAFKA_PORT`` | Port of Kafka message broker (default: 9092) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--kafka_topic KAFKA_TOPIC`` | Topic for metrics (default: my\\_topic) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--kafka_group KAFKA_GROUP`` | Kafka consumer group (default: my\\_group) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--kafka_reader KAFKA_READER`` | Kafka client library to use (kafka\\_python or confluent) (default: kafka\\_influxdb.reader.confluent) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_host INFLUXDB_HOST`` | InfluxDB hostname or IP (default: localhost) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_port INFLUXDB_PORT`` | InfluxDB API port (default: 8086) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_user INFLUXDB_USER`` | InfluxDB username (default: root) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_password INFLUXDB_PASSWORD`` | InfluxDB password (default: root) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_dbname INFLUXDB_DBNAME`` | InfluxDB database to write metrics into (default: metrics) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_use_ssl`` | Use SSL connection for InfluxDB (default: False) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_verify_ssl`` | Verify the SSL certificate before connecting (default: False) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_timeout INFLUXDB_TIMEOUT`` | Max number of seconds to establish a connection to InfluxDB (default: 5) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_use_udp`` | Use UDP connection for InfluxDB (default: False) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_retention_policy INFLUXDB_RETENTION_POLICY`` | Retention policy for incoming metrics (default: autogen) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--influxdb_time_precision INFLUXDB_TIME_PRECISION`` | Precision of incoming metrics. Can be one of 's', 'm', 'ms', 'u' (default: s) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--encoder ENCODER`` | Input encoder which converts an incoming message to dictionary (default: collectd\\_graphite\\_encoder) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--buffer_size BUFFER_SIZE`` | Maximum number of messages that will be collected before flushing to the backend (default: 1000) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``-c CONFIGFILE``, ``--configfile CONFIGFILE`` | Configfile path (default: None) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``-s``, ``--statistics`` | Show performance statistics (default: True) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``-v``, ``--verbose`` | Set verbosity level. Increase verbosity by adding a v: -v -vv -vvv (default: 0) |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n| ``--version`` | Show version |\n+-------------------------------------------------------------+---------------------------------------------------------------------------------------------------------+\n\nComparison with other tools\n---------------------------\n\nThere is a Kafka input plugin and an InfluxDB output plugin for **logstash**. It supports Influxdb 0.9+. We've achieved a message throughput of around **5000 messages/second** with that setup. Check out the configuration at docker/logstash/config.conf. You can run the benchmark yourself:\n\n::\n\n make RUNTIME=logstash\n docker exec -it logstash\n logstash -f config.conf\n\nPlease send a Pull Request if you know of other tools that can be mentioned here.\n\n.. |Build Status| image:: https://travis-ci.org/mre/kafka-influxdb.svg?branch=master\n :target: https://travis-ci.org/mre/kafka-influxdb\n.. |Coverage Status| image:: https://codecov.io/gh/mre/kafka-influxdb/branch/master/graph/badge.svg\n :target: https://codecov.io/gh/mre/kafka-influxdb\n.. |Code Climate| image:: https://codeclimate.com/github/mre/kafka-influxdb/badges/gpa.svg\n :target: https://codeclimate.com/github/mre/kafka-influxdb\n.. |PyPi Version| image:: https://badge.fury.io/py/kafka_influxdb.svg\n :target: https://badge.fury.io/py/kafka_influxdb\n.. |Scrutinizer| image:: https://scrutinizer-ci.com/g/mre/kafka-influxdb/badges/quality-score.png?b=master\n :target: https://scrutinizer-ci.com/g/mre/kafka-influxdb/?branch=master\n.. |image5| image:: https://raw.githubusercontent.com/mre/kafka-influxdb/master/assets/schema-small.png\n.. |Benchmark results| image:: assets/benchmark.png\n\n", "description_content_type": null, "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "http://github.com/mre/kafka-influxdb", "keywords": "kafka influxdb metrics consumer", "license": "Apache", "maintainer": "", "maintainer_email": "", "name": "kafka_influxdb", "package_url": "https://pypi.org/project/kafka_influxdb/", "platform": "", "project_url": "https://pypi.org/project/kafka_influxdb/", "project_urls": { "Homepage": "http://github.com/mre/kafka-influxdb" }, "release_url": "https://pypi.org/project/kafka_influxdb/0.9.3/", "requires_dist": null, "requires_python": "", "summary": "A Kafka consumer for InfluxDB", "version": "0.9.3" }, "last_serial": 3006908, "releases": { "0.4.1": [], "0.5.0": [ { "comment_text": "", "digests": { "md5": "e3ef93f2a94720ecf6dbf1bc6c04dd32", "sha256": "2631f76842b2ac09206653db50acfb8e1b880e913263d64b309b3c3d424ec7e3" }, "downloads": -1, "filename": "kafka_influxdb-0.5.0.tar.gz", "has_sig": false, "md5_digest": "e3ef93f2a94720ecf6dbf1bc6c04dd32", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 10879, "upload_time": "2015-07-14T10:16:12", "url": "https://files.pythonhosted.org/packages/67/da/abda78e564eb26adc6b43832c6cea1ec71d554d12e0b0d6bcd1266ee8cd8/kafka_influxdb-0.5.0.tar.gz" } ], "0.6.0": [ { "comment_text": "", "digests": { "md5": "37ebf5fd4d8cec5309df0648d5d83d95", "sha256": "b617c8fa7c9dc127be1793c83b9cbc9366552056d09ee74256b097bf450b2c33" }, "downloads": -1, "filename": "kafka_influxdb-0.6.0.tar.gz", "has_sig": false, "md5_digest": "37ebf5fd4d8cec5309df0648d5d83d95", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 12724, "upload_time": "2015-10-07T14:13:41", "url": "https://files.pythonhosted.org/packages/d9/22/713432a664d3169072152fb7d9b4707f00fd69cccf46e4b035bfd446dd28/kafka_influxdb-0.6.0.tar.gz" } ], "0.7.0": [], "0.7.1": [ { "comment_text": "", "digests": { "md5": "70de4e170b9e92619aeb844dee54e178", "sha256": "99d9d043d15421d7e2e22eeeef19a6532316cdf3aa5df12db687c3728969a07d" }, "downloads": -1, "filename": "kafka_influxdb-0.7.1.tar.gz", "has_sig": false, "md5_digest": "70de4e170b9e92619aeb844dee54e178", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 13425, "upload_time": "2015-10-20T08:53:57", "url": "https://files.pythonhosted.org/packages/da/1d/c8aad736f8b806e8f43a16a9ce225ef75d5542c003f7a6b8c791bff2801d/kafka_influxdb-0.7.1.tar.gz" } ], "0.7.2": [ { "comment_text": "", "digests": { "md5": "94d47885d0fa0e1a2fc541af874acbe0", "sha256": "5e045c27368d1f0668836e5ec88e86162ae9aa53606eda92ab7886d5283706ef" }, "downloads": -1, "filename": "kafka_influxdb-0.7.2.tar.gz", "has_sig": false, "md5_digest": "94d47885d0fa0e1a2fc541af874acbe0", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 13337, "upload_time": "2015-10-30T08:59:39", "url": "https://files.pythonhosted.org/packages/40/f4/204277e720d57df7bce0d0d9b340bcef44f11ab58e054ee5efc0b5311730/kafka_influxdb-0.7.2.tar.gz" } ], "0.7.3": [ { "comment_text": "", "digests": { "md5": "d1e24694a9ed1edb04edb17db2c61637", "sha256": "c93f7b20edfa11b7462e26e55dca5d34efcec524d08f10313e07c49cf82b414a" }, "downloads": -1, "filename": "kafka_influxdb-0.7.3.tar.gz", "has_sig": false, "md5_digest": "d1e24694a9ed1edb04edb17db2c61637", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 17389, "upload_time": "2016-10-14T14:20:59", "url": "https://files.pythonhosted.org/packages/7d/9b/f6d0acec921aaa7805992a0adfb2bb31b39c3fb29f74879758fcddff0dfc/kafka_influxdb-0.7.3.tar.gz" } ], "0.8.0": [ { "comment_text": "", "digests": { "md5": "5a1a26eb4b5a0fd63107e070361011fd", "sha256": "08224a453dab3bdf8f2c2ce8321c79defb6a302490fe0410d54db4873195207f" }, "downloads": -1, "filename": "kafka_influxdb-0.8.0.tar.gz", "has_sig": false, "md5_digest": "5a1a26eb4b5a0fd63107e070361011fd", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 18249, "upload_time": "2016-11-30T12:49:42", "url": "https://files.pythonhosted.org/packages/6d/17/095b416a9ac380462f273a321516552f125b43c141e780293cf853450be9/kafka_influxdb-0.8.0.tar.gz" } ], "0.8.1": [ { "comment_text": "", "digests": { "md5": "8274c05174a9d7bd0885974de1e83249", "sha256": "25581e72b36e0298a81fe79d6676d574fbbb779de38314797708ab8b599780f2" }, "downloads": -1, "filename": "kafka_influxdb-0.8.1.tar.gz", "has_sig": false, "md5_digest": "8274c05174a9d7bd0885974de1e83249", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 27448, "upload_time": "2017-04-27T11:01:08", "url": "https://files.pythonhosted.org/packages/58/98/06d5c01d0e4e99eda89509f0b60fab905b9a18ad4930827ffa673736dfce/kafka_influxdb-0.8.1.tar.gz" } ], "0.8.3": [ { "comment_text": "", "digests": { "md5": "a36b58f3c4f01b9b8114a7f11f45f83d", "sha256": "a8f6cbc513f35f1936ee6ac58225e252bba099f7f8b4547cfd74d31c1aba5b7f" }, "downloads": -1, "filename": "kafka_influxdb-0.8.3.tar.gz", "has_sig": false, "md5_digest": "a36b58f3c4f01b9b8114a7f11f45f83d", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 30229, "upload_time": "2017-04-27T11:03:20", "url": "https://files.pythonhosted.org/packages/04/a9/2aa6d1808a5333521ebbc7f8720d7138586f21744a1f74f0cdc69affe50b/kafka_influxdb-0.8.3.tar.gz" } ], "0.8.4": [ { "comment_text": "", "digests": { "md5": "7c4cf6aa7b625b66bcb15a53de82d613", "sha256": "c1e438a08903f2ec4eb4d8f831d65f47b3603c100715c5dcce3fe3d79199209a" }, "downloads": -1, "filename": "kafka_influxdb-0.8.4.zip", "has_sig": false, "md5_digest": "7c4cf6aa7b625b66bcb15a53de82d613", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 51072, "upload_time": "2017-04-27T11:18:33", "url": "https://files.pythonhosted.org/packages/0a/2a/275fc1bc373688a101b67f22d023fefa5a0da231f7242424cd51fb2d35a6/kafka_influxdb-0.8.4.zip" } ], "0.9.0": [ { "comment_text": "", "digests": { "md5": "c7ba9562ea33c76b32243c10e4462405", "sha256": "6b9b016a58a0a66f531c1301255c82833ed3e55942915784c23029fb9ca0e75c" }, "downloads": -1, "filename": "kafka_influxdb-0.9.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "c7ba9562ea33c76b32243c10e4462405", "packagetype": "bdist_wheel", "python_version": "2.7", "requires_python": null, "size": 42707, "upload_time": "2017-05-17T20:52:22", "url": "https://files.pythonhosted.org/packages/a4/52/6ea8d92af11995869667f3eb1160aef8dd300232b9c0156b683b881356ae/kafka_influxdb-0.9.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "14e9371723e03ffbfdb472a460666311", "sha256": "03ff6669d0f7a7f617f273aa19f1caca2ba9629acc016a2aae7cc2dc221344e3" }, "downloads": -1, "filename": "kafka_influxdb-0.9.0.zip", "has_sig": false, "md5_digest": "14e9371723e03ffbfdb472a460666311", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 51489, "upload_time": "2017-05-17T20:52:19", "url": "https://files.pythonhosted.org/packages/0b/91/396ee48873afb9e7b0a0977d5d70a89d982763db251a68de0dc1d93b5134/kafka_influxdb-0.9.0.zip" } ], "0.9.1": [ { "comment_text": "", "digests": { "md5": "521184778e63d7dc805db558ec4f0d5d", "sha256": "9ddcb69d4cd414b00c1e1ed48ae370ddb1582cda821f81a7fe8518c936be2956" }, "downloads": -1, "filename": "kafka_influxdb-0.9.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "521184778e63d7dc805db558ec4f0d5d", "packagetype": "bdist_wheel", "python_version": "2.7", "requires_python": null, "size": 42715, "upload_time": "2017-05-17T20:55:26", "url": "https://files.pythonhosted.org/packages/80/b9/7337e1e9fa96eb671f63eb22e7b9c089be7bf7dee38c0412beba5645a48e/kafka_influxdb-0.9.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "893dfa886263273935272bc32c54f251", "sha256": "edad98a55a3365887a81e8fe1d71e1189de8d4b03909ea7bfe64b0e00306ad92" }, "downloads": -1, "filename": "kafka_influxdb-0.9.1.zip", "has_sig": false, "md5_digest": "893dfa886263273935272bc32c54f251", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 51492, "upload_time": "2017-05-17T20:55:22", "url": "https://files.pythonhosted.org/packages/63/b5/927b1bc465d0ed628ff7ccb656f85bd9e1e589c3f1d31a1cfa9377efbf5b/kafka_influxdb-0.9.1.zip" } ], "0.9.2": [ { "comment_text": "", "digests": { "md5": "0d0b9720543b45790eee3bc41785b465", "sha256": "74548050b805c27bbfd1d332e1adb4d97edcfa0d40a8e58d41d7be9704d3b446" }, "downloads": -1, "filename": "kafka_influxdb-0.9.2.tar.gz", "has_sig": false, "md5_digest": "0d0b9720543b45790eee3bc41785b465", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 27129, "upload_time": "2017-07-07T18:07:23", "url": "https://files.pythonhosted.org/packages/a9/10/8e7fe5384e8401ec88f256c23eaa3e3245b63bf42c316e1bee022c5528c6/kafka_influxdb-0.9.2.tar.gz" } ], "0.9.3": [ { "comment_text": "", "digests": { "md5": "31f0aa3b2cbb833f8cf1ade934c3e92b", "sha256": "96b5ef523a004886d7552956a76876c31ae911fa6a5b49dcfd3ca9c19d29c5b8" }, "downloads": -1, "filename": "kafka_influxdb-0.9.3-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "31f0aa3b2cbb833f8cf1ade934c3e92b", "packagetype": "bdist_wheel", "python_version": "2.7", "requires_python": null, "size": 42913, "upload_time": "2017-07-07T18:10:56", "url": "https://files.pythonhosted.org/packages/44/28/4101d992d715090b33552a434bf4f03584e7d19913cc125c7ff86cabc7ca/kafka_influxdb-0.9.3-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "da7d1ed74a6423c6b6126fa56b4329c8", "sha256": "ebab0b5861e07d000b24fe7bb3da33c5f2fe6fda4d8d336a267ef4322eee4586" }, "downloads": -1, "filename": "kafka_influxdb-0.9.3.zip", "has_sig": false, "md5_digest": "da7d1ed74a6423c6b6126fa56b4329c8", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 51749, "upload_time": "2017-07-07T18:10:53", "url": "https://files.pythonhosted.org/packages/fc/55/edd83e6fd6c8f172b44a935fdebf777027135976d6e9fac959b007edd417/kafka_influxdb-0.9.3.zip" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "31f0aa3b2cbb833f8cf1ade934c3e92b", "sha256": "96b5ef523a004886d7552956a76876c31ae911fa6a5b49dcfd3ca9c19d29c5b8" }, "downloads": -1, "filename": "kafka_influxdb-0.9.3-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "31f0aa3b2cbb833f8cf1ade934c3e92b", "packagetype": "bdist_wheel", "python_version": "2.7", "requires_python": null, "size": 42913, "upload_time": "2017-07-07T18:10:56", "url": "https://files.pythonhosted.org/packages/44/28/4101d992d715090b33552a434bf4f03584e7d19913cc125c7ff86cabc7ca/kafka_influxdb-0.9.3-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "da7d1ed74a6423c6b6126fa56b4329c8", "sha256": "ebab0b5861e07d000b24fe7bb3da33c5f2fe6fda4d8d336a267ef4322eee4586" }, "downloads": -1, "filename": "kafka_influxdb-0.9.3.zip", "has_sig": false, "md5_digest": "da7d1ed74a6423c6b6126fa56b4329c8", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 51749, "upload_time": "2017-07-07T18:10:53", "url": "https://files.pythonhosted.org/packages/fc/55/edd83e6fd6c8f172b44a935fdebf777027135976d6e9fac959b007edd417/kafka_influxdb-0.9.3.zip" } ] }