{ "info": { "author": "Christophe-Marie Duquesne", "author_email": "chmd@chmd.fr", "bugtrack_url": null, "classifiers": [ "Development Status :: 4 - Beta", "Intended Audience :: Developers", "License :: OSI Approved :: MIT License", "Operating System :: POSIX :: Linux", "Programming Language :: Python :: 2.7" ], "description": "flasfka\n=======\n\n|Build Status| |Coverage|\n\nPush/Pull on Kafka over HTTP\n\nInstallation\n============\n\nYou can install kafka with pip:\n\n::\n\n pip install kafka\n\nAlternatively, you can build and use the `debian package\n`_.\n\nConfiguration\n=============\n\nTo set up flasfka to talk to the Kafka cluster, the following variables\nare available. Put this in a file (for example ``/etc/flasfka.conf.py``):\n\n::\n\n # Hosts in the kafka cluster (list of ip:port)\n HOSTS=[\"localhost:9092\"]\n\n # You probably don't need to change these\n\n # How long to wait when polling a topic for new messages\n CONSUMER_TIMEOUT=0.1\n\n # Maximum of messages returned when consuming from a topic\n CONSUMER_LIMIT=100\n\n # When you don't specify a group for listening to a topic, flasfka\n # will use this one\n DEFAULT_GROUP=\"flasfka\"\n\n\nThe file will be read at flasfka startup, provided it is in the\nenvironment variable ``FLASFKA_CONFIG``:\n\n::\n\n export FLASFKA_CONFIG=/etc/flasfka.conf.py\n\nRunning flasfka is then just a matter of launching:\n\n::\n\n flasfka-serve\n\nBy default, it runs on the port ``5000``. Use ``flasfka-serve -h`` to\nlearn how to change that. The debian package wraps flasfka into a uwsgi\nservice, so you don't need to worry about this if you are using it.\n\nUsage\n=====\n\nNow, assuming flasfka is configured and running:\n\nsend\n----\n\n::\n\n curl -X POST --data-binary '{\"messages\": [\"msg1\", \"msg2\"]}' \"http://127.0.0.1:5000/my-topic/\"\n\nThis pushes ``msg1`` then ``msg2`` to the topic ``my-topic``.\n\n::\n\n curl -X POST --data-binary '{\"messages\": [\"msg3\"]}' \"http://127.0.0.1:5000/my-topic/my-key/\"\n\nThis pushes ``msg3`` to the topic ``my-topic`` with the key ``my-key``.\n\nfetch\n-----\n\n::\n\n curl http://127.0.0.1:5000/my-topic/\n\nThis retrieves a maximum of 100 of the last messages posted to\n``my-topic``, from the default group ``flasfka``.\n\n::\n\n curl http://127.0.0.1:5000/my-topic/my-group/\n\nThis retrieves a maximum of 100 of the last messages posted to\n``my-topic``, from the group ``my-group``.\n\n::\n\n curl http://127.0.0.1:5000/my-topic/?limit=20\n\nThis retrieves a maximum of 20 of the last messages posted to\n``my-topic``, from the default group ``flasfka``.\n\nLimitations\n===========\n\nFlafska only accepts json data, so your messages need to be in utf-8. If\nyou want to pass arbitrary data, it is recommended to encode them to a\nsuitable format before (e.g. base64).\n\n.. |Build Status| image:: https://travis-ci.org/travel-intelligence/flasfka.svg?branch=master\n :target: https://travis-ci.org/travel-intelligence/flasfka\n\n.. |Coverage| image:: https://coveralls.io/repos/travel-intelligence/flasfka/badge.svg\n :target: https://coveralls.io/r/travel-intelligence/flasfka", "description_content_type": null, "docs_url": null, "download_url": "https://github.com/travel-intelligence/flasfka/archive/1.1.6.tar.gz", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/travel-intelligence/flasfka", "keywords": null, "license": "UNKNOWN", "maintainer": null, "maintainer_email": null, "name": "flasfka", "package_url": "https://pypi.org/project/flasfka/", "platform": "UNKNOWN", "project_url": "https://pypi.org/project/flasfka/", "project_urls": { "Download": "https://github.com/travel-intelligence/flasfka/archive/1.1.6.tar.gz", "Homepage": "https://github.com/travel-intelligence/flasfka" }, "release_url": "https://pypi.org/project/flasfka/1.1.6/", "requires_dist": null, "requires_python": null, "summary": "Push/Pull on Kafka over HTTP", "version": "1.1.6" }, "last_serial": 1525769, "releases": { "1.0.1": [ { "comment_text": "", "digests": { "md5": "72fef02758f86357eaa775b689ccddfd", "sha256": "8a52a6483e77d337457ed1af56d42f5a7cf831727823f7f8d9cd5052b1228a37" }, "downloads": -1, "filename": "flasfka-1.0.1.tar.gz", "has_sig": false, "md5_digest": "72fef02758f86357eaa775b689ccddfd", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4382, "upload_time": "2015-02-19T22:42:32", "url": "https://files.pythonhosted.org/packages/cb/82/84e4ddcab25b82f54127b39fff42e1b48d4addbefe2b62301699e679e232/flasfka-1.0.1.tar.gz" } ], "1.0.2": [ { "comment_text": "", "digests": { "md5": "96990b7a554c2af8af969b4f8fe51841", "sha256": "82829c2ee269ba61cfd76c1c911f2912f5d352a2d86caf63395c46ce51edcc91" }, "downloads": -1, "filename": "flasfka-1.0.2.tar.gz", "has_sig": false, "md5_digest": "96990b7a554c2af8af969b4f8fe51841", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4386, "upload_time": "2015-02-19T22:55:09", "url": "https://files.pythonhosted.org/packages/e4/cc/c618229e25087e3c492f37a0cf7664045fa263b2bfbdd9e0ad985d1df50a/flasfka-1.0.2.tar.gz" } ], "1.1.0": [ { "comment_text": "", "digests": { "md5": "6918ff7068c82af256b57473e3bf5ec8", "sha256": "31dbd9f46f723cf13e80f7120cea6ea0307cb9172b464f2db625ae89197e285f" }, "downloads": -1, "filename": "flasfka-1.1.0.tar.gz", "has_sig": false, "md5_digest": "6918ff7068c82af256b57473e3bf5ec8", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4506, "upload_time": "2015-02-20T11:12:40", "url": "https://files.pythonhosted.org/packages/d1/09/b507105e9cad191676382baf67ebbe2c80c947845072c9b7a4f9796fdafb/flasfka-1.1.0.tar.gz" } ], "1.1.1": [ { "comment_text": "", "digests": { "md5": "00cbac2efab4a6e0909f6e8db6968624", "sha256": "ea13fe5b617eede76a0633e2bca203338bf7bb402e5e55ee13716d0cc375381d" }, "downloads": -1, "filename": "flasfka-1.1.1.tar.gz", "has_sig": false, "md5_digest": "00cbac2efab4a6e0909f6e8db6968624", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4573, "upload_time": "2015-02-23T16:47:13", "url": "https://files.pythonhosted.org/packages/16/5b/d976d195d1a8d014ddcd4429ab90adf09f6bd634a4082700e938945a459c/flasfka-1.1.1.tar.gz" } ], "1.1.2": [ { "comment_text": "", "digests": { "md5": "5b171d2862ce99cb94b0dfe6d4dc1342", "sha256": "f81da0d26f3e9a0c6357dc5977ac0614500ea51c25472c7d80374b859ef73d2f" }, "downloads": -1, "filename": "flasfka-1.1.2.tar.gz", "has_sig": false, "md5_digest": "5b171d2862ce99cb94b0dfe6d4dc1342", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4524, "upload_time": "2015-02-23T17:12:50", "url": "https://files.pythonhosted.org/packages/d0/83/9d93c5a3f9ac406d91408c5764a98bd956ccf7bace95d7a83280615fd9d5/flasfka-1.1.2.tar.gz" } ], "1.1.3": [ { "comment_text": "", "digests": { "md5": "d40d9d3c758d734c3a919eb59907f03e", "sha256": "31b760f7c2e289a6547b6b7095c2c7fb520c31802436816702eb3aacd856b331" }, "downloads": -1, "filename": "flasfka-1.1.3.tar.gz", "has_sig": false, "md5_digest": "d40d9d3c758d734c3a919eb59907f03e", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4575, "upload_time": "2015-02-25T10:57:01", "url": "https://files.pythonhosted.org/packages/ee/56/83f0dd2ec74bd855aa830f616abb686c8d43e5ca91fabc1ab97834f41a22/flasfka-1.1.3.tar.gz" } ], "1.1.4": [ { "comment_text": "", "digests": { "md5": "4790911979ebcdb3faf14c5298472a2f", "sha256": "d1df92e1a279d15711c9e28bcb5115b639fbb234134d2343c153fd03283fd00c" }, "downloads": -1, "filename": "flasfka-1.1.4.tar.gz", "has_sig": false, "md5_digest": "4790911979ebcdb3faf14c5298472a2f", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4970, "upload_time": "2015-02-26T09:02:19", "url": "https://files.pythonhosted.org/packages/82/2b/a52550298128242c615480f9a7c474a381d0c65fcf52bfe222311c59b5e4/flasfka-1.1.4.tar.gz" } ], "1.1.5": [ { "comment_text": "", "digests": { "md5": "aedfb0782f2f65d3a3474d82d6d201e3", "sha256": "84fb52f298f182c54af9caa01e9610d91fb342f81a08e5b154a5e7e1fa96d2af" }, "downloads": -1, "filename": "flasfka-1.1.5.tar.gz", "has_sig": false, "md5_digest": "aedfb0782f2f65d3a3474d82d6d201e3", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4981, "upload_time": "2015-02-26T09:08:53", "url": "https://files.pythonhosted.org/packages/fc/71/3bae387dd2310a5bb78214aee09b723cc34316c3033ddc61957c96ed4617/flasfka-1.1.5.tar.gz" } ], "1.1.6": [ { "comment_text": "", "digests": { "md5": "3d03c0e8ec25ac1475b5cf5f0de09ac1", "sha256": "01a407ee764f37da633611ac883e6f7cfd1a69026c382f89a07ffcdd8cbb58e3" }, "downloads": -1, "filename": "flasfka-1.1.6.tar.gz", "has_sig": false, "md5_digest": "3d03c0e8ec25ac1475b5cf5f0de09ac1", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5193, "upload_time": "2015-02-27T10:22:58", "url": "https://files.pythonhosted.org/packages/31/76/fcd549523c0d1bb601bec457e07b8f9accd91c6e62540ee141372b4c56e1/flasfka-1.1.6.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "3d03c0e8ec25ac1475b5cf5f0de09ac1", "sha256": "01a407ee764f37da633611ac883e6f7cfd1a69026c382f89a07ffcdd8cbb58e3" }, "downloads": -1, "filename": "flasfka-1.1.6.tar.gz", "has_sig": false, "md5_digest": "3d03c0e8ec25ac1475b5cf5f0de09ac1", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5193, "upload_time": "2015-02-27T10:22:58", "url": "https://files.pythonhosted.org/packages/31/76/fcd549523c0d1bb601bec457e07b8f9accd91c6e62540ee141372b4c56e1/flasfka-1.1.6.tar.gz" } ] }