{ "info": { "author": "Rudinei Goi Roecker", "author_email": "rudinei.roecker@gmail.com", "bugtrack_url": null, "classifiers": [ "Development Status :: 3 - Alpha", "Intended Audience :: Developers", "License :: OSI Approved :: MIT License", "Programming Language :: Python :: 3", "Programming Language :: Python :: 3.6", "Topic :: Software Development :: Libraries :: Application Frameworks" ], "description": "# Simple AMQP\n\nA simple AMQP lib for Python\n\n## Installation\n\n```bash\n# Asyncio\npip install simple-amqp[asyncio]\n\n# Gevent\npip install simple-amqp[gevent]\n```\n\n## Example usage\n\n```python\n# Asyncio\nfrom asyncio import get_event_loop, sleep\n\nfrom simple_amqp import AmqpMsg, AmqpParameters\nfrom simple_amqp.asyncio import AsyncioAmqpConnection\n\nconn = AsyncioAmqpConnection(AmqpParameters(host='localhost'))\nchannel = conn.channel()\n\nexchange = channel.exchange('exchange.name', 'topic', durable=True)\n\n\nasync def msg_received(msg: AmqpMsg):\n if msg.payload == b'ok':\n return True # ack msg\n\n return False # nack msg\n\n\nchannel \\\n .queue('queue.name', durable=True) \\\n .bind(exchange, 'topic.name') \\\n .consume(msg_received)\n\n\nasync def main():\n await conn.start()\n await channel.publish(AmqpMsg(\n exchange='exchange.name',\n topic='topic.name',\n payload=b'ok',\n ))\n\n await sleep(1)\n await conn.stop()\n\nloop = get_event_loop()\nloop.run_until_complete(main)\n```\n\n```python\n# Gevent\nfrom gevent import monkey\nmonkey.patch_all()\n\nfrom time import sleep\n\nfrom simple_amqp import AmqpMsg, AmqpParameters\nfrom simple_amqp.gevent import GeventAmqpConnection\n\nconn = GeventAmqpConnection(AmqpParameters(host='localhost'))\nchannel = conn.channel()\n\nexchange = channel.exchange('exchange.name', 'topic', durable=True)\n\n\ndef msg_received(msg: AmqpMsg):\n if msg.payload == b'ok':\n return True # ack msg\n\n return False # nack msg\n\n\nchannel \\\n .queue('queue.name', durable=True) \\\n .bind(exchange, 'topic.name') \\\n .consume(msg_received)\n\nconn.start()\n\nchannel.publish(AmqpMsg(\n exchange='exchange.name',\n topic='topic.name',\n payload=b'ok',\n))\n\nsleep(1)\nconn.stop()\n```\n\n\n", "description_content_type": "text/markdown", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/rudineirk/py-simple-amqp", "keywords": "simple amqp", "license": "MIT", "maintainer": "", "maintainer_email": "", "name": "simple-amqp", "package_url": "https://pypi.org/project/simple-amqp/", "platform": "", "project_url": "https://pypi.org/project/simple-amqp/", "project_urls": { "Homepage": "https://github.com/rudineirk/py-simple-amqp" }, "release_url": "https://pypi.org/project/simple-amqp/0.2.6/", "requires_dist": [ "pika (<0.11,>=0.10)", "aio-pika; extra == 'asyncio'", "gevent; extra == 'gevent'" ], "requires_python": "", "summary": "Simple AMQP lib", "version": "0.2.6" }, "last_serial": 4096739, "releases": { "0.0.2": [ { "comment_text": "", "digests": { "md5": "bba4846aed6f34ae91dade4f80f16770", "sha256": "f9c58080d1a5350c6c612262bf982ece79567e3b9bcbf05a67209af2166cbc72" }, "downloads": -1, "filename": "simple_amqp-0.0.2-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "bba4846aed6f34ae91dade4f80f16770", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11101, "upload_time": "2018-05-15T13:51:25", "url": "https://files.pythonhosted.org/packages/fd/b8/8ad2e9f3126998f1e719175afd7bc9a1a88b84b0a0cf0960afcdd0a9302e/simple_amqp-0.0.2-py2.py3-none-any.whl" } ], "0.1.0": [ { "comment_text": "", "digests": { "md5": "bf64705127d2b6e017282cf112475408", "sha256": "a6865c21496f3dd74c280cd6633498b8f2c4c0569b4363dd2f9f913216d01b97" }, "downloads": -1, "filename": "simple_amqp-0.1.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "bf64705127d2b6e017282cf112475408", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11133, "upload_time": "2018-05-17T17:00:55", "url": "https://files.pythonhosted.org/packages/90/0e/0e29c3562ae02aa5f4153c91050ff6ba79426e064363fdc764cc62b7abe0/simple_amqp-0.1.0-py2.py3-none-any.whl" } ], "0.1.1": [ { "comment_text": "", "digests": { "md5": "74340a721eba7e9383b1e4e46cb5eea6", "sha256": "fa38e83091ee30f80706cc55187e4b15cdb453c9acb9107e889c4a91b9ee6a0a" }, "downloads": -1, "filename": "simple_amqp-0.1.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "74340a721eba7e9383b1e4e46cb5eea6", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11215, "upload_time": "2018-05-25T12:21:03", "url": "https://files.pythonhosted.org/packages/c2/4b/2cb0c73c601e72c46e54afde5de31f0f4880c0b1ffcae6f3f58258a296d8/simple_amqp-0.1.1-py2.py3-none-any.whl" } ], "0.1.2": [ { "comment_text": "", "digests": { "md5": "da8f265681fdaede8c16a0747531c2a5", "sha256": "d63a61974ddbb1b8616bd617a897803d04247f2d1e5b3c5cd334480afc36de15" }, "downloads": -1, "filename": "simple_amqp-0.1.2-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "da8f265681fdaede8c16a0747531c2a5", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11284, "upload_time": "2018-05-25T12:58:04", "url": "https://files.pythonhosted.org/packages/b6/7d/9bafa41dd333c587c91f3c550c0c34784fb9cfbefa4337b1a3cecba3f12f/simple_amqp-0.1.2-py2.py3-none-any.whl" } ], "0.1.3": [ { "comment_text": "", "digests": { "md5": "e3fa425e9b3c1b5db04836e692cda79c", "sha256": "bec2c552a2bc5c965bc8abb995b285b0417f7006256edff9f2b4c6b302130c24" }, "downloads": -1, "filename": "simple_amqp-0.1.3-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "e3fa425e9b3c1b5db04836e692cda79c", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11299, "upload_time": "2018-06-05T13:20:58", "url": "https://files.pythonhosted.org/packages/0c/3b/20bad8ad7f1472e517f89205d855a3e9c3fca6ec33f7784771d7b6d5432b/simple_amqp-0.1.3-py2.py3-none-any.whl" } ], "0.2.0": [ { "comment_text": "", "digests": { "md5": "9d381cccd9b5b02bb04a4aedabe46487", "sha256": "1c01ef9f8cc6a6f2cb3d29aab7d686ef2ee1fdb17cb0aca02804428184cb92fb" }, "downloads": -1, "filename": "simple_amqp-0.2.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "9d381cccd9b5b02bb04a4aedabe46487", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11889, "upload_time": "2018-06-20T18:11:45", "url": "https://files.pythonhosted.org/packages/33/ea/5771338e68340a7431f506de1cabc1f465635bb3d112b79b7bbcfdb96612/simple_amqp-0.2.0-py2.py3-none-any.whl" } ], "0.2.1": [ { "comment_text": "", "digests": { "md5": "ed035af5ee5164db2479291d109894ca", "sha256": "4557b4b6066b009d6270601ffc789c20d29b25e04dd9a2ee07f42de210c144a0" }, "downloads": -1, "filename": "simple_amqp-0.2.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "ed035af5ee5164db2479291d109894ca", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11896, "upload_time": "2018-06-20T19:38:28", "url": "https://files.pythonhosted.org/packages/ab/21/45b5ceb37b02c3c18aa4a17ae3abb8cf91371034e946b4c0d179eba92d55/simple_amqp-0.2.1-py2.py3-none-any.whl" } ], "0.2.2": [ { "comment_text": "", "digests": { "md5": "651d12dbb58b0e44ea4180fa9527de1a", "sha256": "4e0a103aea229cbc8ee7b6341cb160391f75df809a1d2012af034fc7abf894da" }, "downloads": -1, "filename": "simple_amqp-0.2.2-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "651d12dbb58b0e44ea4180fa9527de1a", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11768, "upload_time": "2018-06-20T23:37:02", "url": "https://files.pythonhosted.org/packages/73/08/cbeece786f9f91be4c2e6a8e27cdc3bba15e898f037731b9aabb9da6f8f8/simple_amqp-0.2.2-py2.py3-none-any.whl" } ], "0.2.3": [ { "comment_text": "", "digests": { "md5": "593c966c29a5eccb9999d182baa21784", "sha256": "2da75c7a69ef6c0998effb19bab93272524eb7c26a22bc6ac10529b994d06a97" }, "downloads": -1, "filename": "simple_amqp-0.2.3-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "593c966c29a5eccb9999d182baa21784", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11773, "upload_time": "2018-06-20T23:52:45", "url": "https://files.pythonhosted.org/packages/e5/c4/5545743fb9f3a5a23c93d36adf3470ffa94a71c4089c2d47bfba35e7c22a/simple_amqp-0.2.3-py2.py3-none-any.whl" } ], "0.2.4": [ { "comment_text": "", "digests": { "md5": "5065d654989d1399085e230cf6e9435a", "sha256": "b06ab57769da80864f4432ced32242c4e0376360bf00fcafba22f8a63bb7ee26" }, "downloads": -1, "filename": "simple_amqp-0.2.4-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "5065d654989d1399085e230cf6e9435a", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11846, "upload_time": "2018-06-21T00:25:42", "url": "https://files.pythonhosted.org/packages/4f/a1/0b1ee293cda94e3b260d47dce17ecd411de1d9abc46dafda186b5f4f15b8/simple_amqp-0.2.4-py2.py3-none-any.whl" } ], "0.2.5": [ { "comment_text": "", "digests": { "md5": "e7980f014d312cfcc38aac86b653fb45", "sha256": "ccdaa80e708a078252b1dce46d7da3d53fc9b87f7ee414e59ec0c70478a0d5bb" }, "downloads": -1, "filename": "simple_amqp-0.2.5-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "e7980f014d312cfcc38aac86b653fb45", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11856, "upload_time": "2018-06-21T00:41:05", "url": "https://files.pythonhosted.org/packages/5a/d9/3ca96da0a6368bb14070291bdc9cc980f984be99efe81501225ca71cbf96/simple_amqp-0.2.5-py2.py3-none-any.whl" } ], "0.2.6": [ { "comment_text": "", "digests": { "md5": "cb348bb08762265a5d15a2164d890a19", "sha256": "d553554c46e4fd99f9534e4db4f9dfaf8544afd4d0d3dcabf4680550593aed60" }, "downloads": -1, "filename": "simple_amqp-0.2.6-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "cb348bb08762265a5d15a2164d890a19", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11893, "upload_time": "2018-07-24T12:14:02", "url": "https://files.pythonhosted.org/packages/5c/ed/a71dbacdbce1fe29ef9d6e94395243aa330e27088a40f4cc51700fdf6453/simple_amqp-0.2.6-py2.py3-none-any.whl" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "cb348bb08762265a5d15a2164d890a19", "sha256": "d553554c46e4fd99f9534e4db4f9dfaf8544afd4d0d3dcabf4680550593aed60" }, "downloads": -1, "filename": "simple_amqp-0.2.6-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "cb348bb08762265a5d15a2164d890a19", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": null, "size": 11893, "upload_time": "2018-07-24T12:14:02", "url": "https://files.pythonhosted.org/packages/5c/ed/a71dbacdbce1fe29ef9d6e94395243aa330e27088a40f4cc51700fdf6453/simple_amqp-0.2.6-py2.py3-none-any.whl" } ] }