{ "info": { "author": "Christian Balcom", "author_email": "robot.inventor@gmail.com", "bugtrack_url": null, "classifiers": [], "description": "# simplestreamer\n\nThis is a tiny (< 150 loc) peer-to-peer data-streaming library designed for high-frequency status data.\nIt uses pickle underneath to serialize the data, so you can dump any python object through it.\n\nYou can install it with\n``pip install simplestreamer``\n\nHere is a quick example of how to use it. Hopefully it is self-explanatory enough.\n\nnode 1 code: ::\n\n # just dumps time data into the streamer at 100 hz\n import simplestreamer\n import time\n\n streamer = simplestreamer.SimpleStreamer(5200)\n\n while True:\n streamer.send_data({\"current time.time()\": time.time()})\n time.sleep(0.01)\n\n\nnode 2 (and 3, and 4, and so on) code: ::\n\n # subscribes to the stream from node 1 and periodically reads the data\n import simplestreamer\n import time\n\n streamer = simplestreamer.SimpleStreamer(5201)\n streamer.subscribe(\"127.0.0.1\", 5200, \"streamer 1\")\n # You can optionally configure the rate at which the remote streamer sends you data\n #streamer.subscribe(\"127.0.0.1\", 5200, \"streamer 1\", updates_per_sec=1.5)\n\n while True:\n print(streamer.get_data(\"streamer 1\"))\n time.sleep(0.5)", "description_content_type": null, "docs_url": null, "download_url": "UNKNOWN", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/computer-whisperer/simplestreamer", "keywords": "networking", "license": "UNKNOWN", "maintainer": null, "maintainer_email": null, "name": "simplestreamer", "package_url": "https://pypi.org/project/simplestreamer/", "platform": "UNKNOWN", "project_url": "https://pypi.org/project/simplestreamer/", "project_urls": { "Download": "UNKNOWN", "Homepage": "https://github.com/computer-whisperer/simplestreamer" }, "release_url": "https://pypi.org/project/simplestreamer/2016.0.3/", "requires_dist": null, "requires_python": null, "summary": "A tiny peer-to-peer data-streaming library", "version": "2016.0.3" }, "last_serial": 1965997, "releases": { "2016.0.2": [], "2016.0.3": [ { "comment_text": "", "digests": { "md5": "4aeacf7f68a820daf70f5206ef2f510c", "sha256": "df6954a58fcafad2881dae9de593e40eaa0f34d53a42aea6267a36fd9ca27915" }, "downloads": -1, "filename": "simplestreamer-2016.0.3.tar.gz", "has_sig": false, "md5_digest": "4aeacf7f68a820daf70f5206ef2f510c", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3369, "upload_time": "2016-02-19T21:21:57", "url": "https://files.pythonhosted.org/packages/c2/0c/bbce0d1f3ba282125cd58a4d474a01d4f285934f4c23bf5b5b93e2983064/simplestreamer-2016.0.3.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "4aeacf7f68a820daf70f5206ef2f510c", "sha256": "df6954a58fcafad2881dae9de593e40eaa0f34d53a42aea6267a36fd9ca27915" }, "downloads": -1, "filename": "simplestreamer-2016.0.3.tar.gz", "has_sig": false, "md5_digest": "4aeacf7f68a820daf70f5206ef2f510c", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3369, "upload_time": "2016-02-19T21:21:57", "url": "https://files.pythonhosted.org/packages/c2/0c/bbce0d1f3ba282125cd58a4d474a01d4f285934f4c23bf5b5b93e2983064/simplestreamer-2016.0.3.tar.gz" } ] }