{ "info": { "author": "The Swarm Team", "author_email": "dev@hiventy.com", "bugtrack_url": null, "classifiers": [ "Intended Audience :: Developers", "Operating System :: OS Independent", "Programming Language :: Python", "Programming Language :: Python :: 2.7", "Topic :: Software Development" ], "description": "Swarm-Bus\n=========\n\nClient side implementation of an ESB via Amazon SQS.\n\nSimple Usage\n------------\n\n::\n\n uri = 'sqs://LOGIN:PASSWORD@'\n transport = {\n 'region': 'eu-west-1',\n 'exchange': 'swarm',\n 'queue_name_prefix': 'dev-%(hostname)s-',\n 'office_hours': False,\n 'use_priorities': True,\n 'priorities': ['low', 'high']\n }\n queues = {\n 'my_queue': {\n 'route': 'my.queue.route', # Specific route\n 'sleep': 60, # Seconds before next call to SQS\n 'visibility': 1800, # Visibility message in queue\n 'wait': 10 # Long polling seconds\n },\n 'my_second_queue': {} # Will be automaticaly filled/completed\n }\n\n bus = AMQP(uri, transport, queues)\n bus.connect()\n\n # We purge a known queue\n bus.purge_queue('my_queue')\n\n # Now we add a new queue on the fly\n bus.register_queue('new_queue', {'wait': 20})\n\n bus.close()\n\n\nUsing as a producer\n-------------------\n\n::\n\n with AMQP(uri, transport, queues) as producer:\n producer.publish(\n 'my_queue',\n {'id': 42},\n 1 # Optional, specify 'high' priority queue\n )\n\n\nUsing as a consumer\n-------------------\n\n::\n\n def print_routing_key(body, message):\n id_ = body['id']\n rk = message.delivery_info['routing_key']\n print(\"[x] %r:%r\" % (rk, id_))\n\n def ack_message(body, message):\n message.ack()\n\n def error_handler(body, message):\n raise ValueError('Error while processing message')\n\n with AMQP(uri, transport, queues) as consumer:\n consumer.consume(\n 'my_queue',\n [print_routing_key, ack_message],\n error_handler\n )\n\n\n", "description_content_type": "", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://bitbucket.org/monalgroup/swarm-bus", "keywords": "ESB,tools,swarm,bus", "license": "GPL License", "maintainer": "", "maintainer_email": "", "name": "swarm-bus", "package_url": "https://pypi.org/project/swarm-bus/", "platform": "", "project_url": "https://pypi.org/project/swarm-bus/", "project_urls": { "Homepage": "https://bitbucket.org/monalgroup/swarm-bus" }, "release_url": "https://pypi.org/project/swarm-bus/3.4.2/", "requires_dist": [ "boto (==2.49.0)", "kombu (==4.0.2)" ], "requires_python": "", "summary": "AMQP layer for communicating with the ESB.", "version": "3.4.2" }, "last_serial": 4638930, "releases": { "2.1": [ { "comment_text": "", "digests": { "md5": "255bc0a5e5f46aede8214e799eda7076", "sha256": "ba3f22495410a8534be7336861e273a2bbde541bee6e74e497d0211cfdd6bb05" }, "downloads": -1, "filename": "swarm_bus-2.1-py2-none-any.whl", "has_sig": false, "md5_digest": "255bc0a5e5f46aede8214e799eda7076", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 5597, "upload_time": "2018-02-22T12:15:55", "url": "https://files.pythonhosted.org/packages/86/1d/6c884f2ab1d3fa8f63a2da1983eccd7e390f3bf15312796f8d1629bde656/swarm_bus-2.1-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "02cd7dd7c38f6574100bda85cc8ea7dd", "sha256": "85c2771247a243ddb2fef1edafa3696d4936eba58b366d1f86861a7e7b3076f1" }, "downloads": -1, "filename": "swarm-bus-2.1.tar.gz", "has_sig": false, "md5_digest": "02cd7dd7c38f6574100bda85cc8ea7dd", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3898, "upload_time": "2018-02-22T12:15:56", "url": "https://files.pythonhosted.org/packages/b0/15/9e88702683d2df1a3c3da232582053dd0a3aeb9e89b4b459461d323b21ad/swarm-bus-2.1.tar.gz" } ], "3.0": [ { "comment_text": "", "digests": { "md5": "4cf9ee7f445653f78c9367e17564ef56", "sha256": "67325634da6bda0c0738a3c189efc684acb613c2805ea9c52b6d2a4d144a9a83" }, "downloads": -1, "filename": "swarm_bus-3.0-py2-none-any.whl", "has_sig": false, "md5_digest": "4cf9ee7f445653f78c9367e17564ef56", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 6176, "upload_time": "2018-08-06T09:35:12", "url": "https://files.pythonhosted.org/packages/ac/9b/8c37500790f4e7d61f4a1b01835e855ab90e806f437c5088c03d01f4f8e0/swarm_bus-3.0-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "90c317217e0431e4510ff18f3b200ec9", "sha256": "8d4efd914e024342109eb877753810db406ede932c1abac784ebb97febc1b225" }, "downloads": -1, "filename": "swarm-bus-3.0.tar.gz", "has_sig": false, "md5_digest": "90c317217e0431e4510ff18f3b200ec9", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4840, "upload_time": "2018-08-06T09:35:13", "url": "https://files.pythonhosted.org/packages/79/86/9aa37e72e77fc58918eb0fc3b043ea3b8bf5ca6abb2b9821b4fac33635aa/swarm-bus-3.0.tar.gz" } ], "3.1": [ { "comment_text": "", "digests": { "md5": "ddd725533a6153102e61ac819bc90f92", "sha256": "d06f536745419b3ff5a9b1777cb6f6b271e4961efc4ef79a0a686ae39f41be15" }, "downloads": -1, "filename": "swarm_bus-3.1-py2-none-any.whl", "has_sig": false, "md5_digest": "ddd725533a6153102e61ac819bc90f92", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 7800, "upload_time": "2018-08-13T10:22:03", "url": "https://files.pythonhosted.org/packages/cd/a4/65fb196428f3ca6a95a2e3d93d7d97fbf2b353467d8edc0b132242953732/swarm_bus-3.1-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "e482eaeb9ab4e4786db781244851cb18", "sha256": "8424b6f0bc9e062458f6d01f5187c091591842c4a6756626561229069e13f796" }, "downloads": -1, "filename": "swarm-bus-3.1.tar.gz", "has_sig": false, "md5_digest": "e482eaeb9ab4e4786db781244851cb18", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5075, "upload_time": "2018-08-13T10:22:05", "url": "https://files.pythonhosted.org/packages/27/e7/b55b97c34a2d553a212eb699c9c5e4ed68a05ee502b474904334ea708afb/swarm-bus-3.1.tar.gz" } ], "3.2": [ { "comment_text": "", "digests": { "md5": "b215bc847de6340732351181a1105f8b", "sha256": "e0fc117acedc8a68b16e7e35a233ba9b3029606592ef1a65a8cdcb5aa2dfdc51" }, "downloads": -1, "filename": "swarm_bus-3.2-py2-none-any.whl", "has_sig": false, "md5_digest": "b215bc847de6340732351181a1105f8b", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 7797, "upload_time": "2018-08-13T11:37:55", "url": "https://files.pythonhosted.org/packages/95/be/f40b892e6bf9143426cbccb8cfe472192ace223ee927c3991f2857ff2a39/swarm_bus-3.2-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "815575abe91e6c68c475d3c691f57a6c", "sha256": "34c1320cfe0fb20da9d368ed516236c50b56da8fa7e6dbbc8a5c4a83c2575a5a" }, "downloads": -1, "filename": "swarm-bus-3.2.tar.gz", "has_sig": false, "md5_digest": "815575abe91e6c68c475d3c691f57a6c", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5077, "upload_time": "2018-08-13T11:37:56", "url": "https://files.pythonhosted.org/packages/6f/e4/f5ff774c71b39c1b917d89328bd3a903222dd4f19635497de2b824946a99/swarm-bus-3.2.tar.gz" } ], "3.3": [ { "comment_text": "", "digests": { "md5": "33f14e81ce18d0feaa46618ed7be0a37", "sha256": "cf0a629afa173eb3a15dce23566cf2bfaf9c41d4887faa90e10cf7048beaa654" }, "downloads": -1, "filename": "swarm_bus-3.3-py2-none-any.whl", "has_sig": false, "md5_digest": "33f14e81ce18d0feaa46618ed7be0a37", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 8034, "upload_time": "2018-08-14T13:42:36", "url": "https://files.pythonhosted.org/packages/59/71/241c58b6ee78613607572922724508a43b882e43d785321e0e1a9c61dec0/swarm_bus-3.3-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "68da654c29176df61273c087c24ab3a4", "sha256": "cd53ea3f6c16e3b3edbeeccfaded2a3a0ae98e57d969d8ec75f68ec606f3003f" }, "downloads": -1, "filename": "swarm-bus-3.3.tar.gz", "has_sig": false, "md5_digest": "68da654c29176df61273c087c24ab3a4", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5223, "upload_time": "2018-08-14T13:42:37", "url": "https://files.pythonhosted.org/packages/ae/fa/1d58e1fb3292c89843a9b3dddd0288c593d36e07ef021bf1249dab1182e9/swarm-bus-3.3.tar.gz" } ], "3.4": [ { "comment_text": "", "digests": { "md5": "3ae9ca64e5ff90b1c17f83993786eaa7", "sha256": "f84d6b42e54cb388b6d3045f0db7db6f55ba894b565af5782f46cbca333ba6b3" }, "downloads": -1, "filename": "swarm_bus-3.4-py2-none-any.whl", "has_sig": false, "md5_digest": "3ae9ca64e5ff90b1c17f83993786eaa7", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 7770, "upload_time": "2018-12-20T22:26:07", "url": "https://files.pythonhosted.org/packages/22/26/1f8be66a56db1e17600c4be3df5726d9b49ecd4ceca3ee03e3a9bddcc57e/swarm_bus-3.4-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "3bdf3e6cd2a3df22c39e799170a6f394", "sha256": "c3462c39872e014329a69fafb4e09e2caf53fc7e2427b9458ebaf288a29542b6" }, "downloads": -1, "filename": "swarm-bus-3.4.tar.gz", "has_sig": false, "md5_digest": "3bdf3e6cd2a3df22c39e799170a6f394", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5499, "upload_time": "2018-12-20T22:26:09", "url": "https://files.pythonhosted.org/packages/ea/ee/4802475a8a2334245e8933a43d3a4e36a0925b9162abfb41596e85e225ef/swarm-bus-3.4.tar.gz" } ], "3.4.1": [ { "comment_text": "", "digests": { "md5": "f5d0a388f92c02893ad3b762c1858607", "sha256": "320e8d08d9f5883fb21652b441cd477a53ee4c23c1ea41c9594ca0e9db311a03" }, "downloads": -1, "filename": "swarm_bus-3.4.1-py2-none-any.whl", "has_sig": false, "md5_digest": "f5d0a388f92c02893ad3b762c1858607", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 7882, "upload_time": "2018-12-20T23:10:12", "url": "https://files.pythonhosted.org/packages/3d/15/a4c781635579f9da423e642d1bea60306db70bd88da643e4494c39f6b358/swarm_bus-3.4.1-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "ce0c355bc877960257c7256151116439", "sha256": "eac4cf9f8b05fad43d991e8213b970328d2c54019a3f36fb1cf125f830d35a47" }, "downloads": -1, "filename": "swarm-bus-3.4.1.tar.gz", "has_sig": false, "md5_digest": "ce0c355bc877960257c7256151116439", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5582, "upload_time": "2018-12-20T23:10:14", "url": "https://files.pythonhosted.org/packages/bf/51/6342b2204353a9e3c3f40c5fedb5e3d97bee741580619537818d8cf7873d/swarm-bus-3.4.1.tar.gz" } ], "3.4.2": [ { "comment_text": "", "digests": { "md5": "bb38aba4acc8550eaddfbe240163be00", "sha256": "165f2db3b4f20ca38cc528b35e08544f3ba8240b4c2e57cea4022531e3d00319" }, "downloads": -1, "filename": "swarm_bus-3.4.2-py2-none-any.whl", "has_sig": false, "md5_digest": "bb38aba4acc8550eaddfbe240163be00", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 7945, "upload_time": "2018-12-27T20:27:29", "url": "https://files.pythonhosted.org/packages/4b/09/87e8639cd8d911c39e909a493161edf6244e8e54cf41aefda29a8d5e4de7/swarm_bus-3.4.2-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "716d9c12ef4bd0c0316f7c83a6db7ac9", "sha256": "9c63bfe17128f72a690993386d17c6019df0b71f4528d258a047185c32beccbf" }, "downloads": -1, "filename": "swarm-bus-3.4.2.tar.gz", "has_sig": false, "md5_digest": "716d9c12ef4bd0c0316f7c83a6db7ac9", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5652, "upload_time": "2018-12-27T20:27:32", "url": "https://files.pythonhosted.org/packages/fc/c0/153f451f29d85a8ee174918916d534464961c7a416c0b8fa309be8e97ced/swarm-bus-3.4.2.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "bb38aba4acc8550eaddfbe240163be00", "sha256": "165f2db3b4f20ca38cc528b35e08544f3ba8240b4c2e57cea4022531e3d00319" }, "downloads": -1, "filename": "swarm_bus-3.4.2-py2-none-any.whl", "has_sig": false, "md5_digest": "bb38aba4acc8550eaddfbe240163be00", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 7945, "upload_time": "2018-12-27T20:27:29", "url": "https://files.pythonhosted.org/packages/4b/09/87e8639cd8d911c39e909a493161edf6244e8e54cf41aefda29a8d5e4de7/swarm_bus-3.4.2-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "716d9c12ef4bd0c0316f7c83a6db7ac9", "sha256": "9c63bfe17128f72a690993386d17c6019df0b71f4528d258a047185c32beccbf" }, "downloads": -1, "filename": "swarm-bus-3.4.2.tar.gz", "has_sig": false, "md5_digest": "716d9c12ef4bd0c0316f7c83a6db7ac9", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5652, "upload_time": "2018-12-27T20:27:32", "url": "https://files.pythonhosted.org/packages/fc/c0/153f451f29d85a8ee174918916d534464961c7a416c0b8fa309be8e97ced/swarm-bus-3.4.2.tar.gz" } ] }