{ "info": { "author": "Avanti FS", "author_email": "alonso6230@gmail.com", "bugtrack_url": null, "classifiers": [ "License :: OSI Approved :: GNU General Public License v3 (GPLv3)", "Programming Language :: Python", "Programming Language :: Python :: 3", "Programming Language :: Python :: 3.6", "Programming Language :: Python :: Implementation :: CPython", "Programming Language :: Python :: Implementation :: PyPy" ], "description": "\n# PyAMQP\n\nPython interface for simple usage of AMQP middleware applications.\n\nThis interface is made to ease the process of using AMQP software.\n\nThe applications supported so far:\n\n* RabbitMQ: This is a popular open-source message-broker that implemented \n the Advanced Message Queuing Protocol (AMQP) written in the Erlang programming language\n\n# How to get it\n``pip install pyamqp``\n\n# Dependencies\n[Pika](https://github.com/pika/pika): 0.13 or higher\n\n[pytest](https://pytest.org/): 4.0.2 or higher\n\n# Usage example\n ## RabbitMQ - Receiver\n``` \nfrom pyamqp.rabbit.receiver import Receiver\n\n# Initializing and creating the connection with the Rabbit server\nreceiver_instance = Receiver(host='18.222.222.222',\n port=5672,\n user='guest',\n password='1245554221')\n\n# Declares the queue with the specified parameters, \n# binds it to an exchange using the routing_keys list.\nreceiver_instance.connect_queue(queue_name='test',\n exchange='test_exchange',\n routing_keys=['A', 'B'],\n is_durable=True,\n auto_delete=False)\n# callback function\n# Not necesary if inheritance is used\ndef get_message(message, details):\n some_value = message.get('some_key', None)\n print(some_value)\n\nreceiver_instance.consume(callback_function=get_message,\n no_ack=True,\n consumer_tag='AAAAKKK_2232')\n```\n## Rabbit-Dispatcher\n```\nfrom pyamqp.rabbit.dispatcher import Dispatcher\n\ndispatcher_instance = Dispatcher(host='18.222.222.222',\n port=5672,\n user='guest',\n password='1245554221')\n\n# Declaring exchanges that are going to be used for sending messages\n# exchanges parameter can be an string or a list of strings \ndispatcher_instance.connect_exchanges(exchanges=['test_exch', 'test_exch_2],\n exchange_type='topic',\n auto_delete=True)\n\n\n# There can be only two types of passed messages, string or dicts.\nmessage_1 = 'Hello'\nmessage_2 = {'Ciao': 'Hola'} \n\ndispatcher.send_message(message_1, 'THIS.IS.A.KEY', 'test_exch')\ndispatcher.send_message(message_2, 'KEY.SOMETHING', 'test_exch_2')\n```\n\n# Current limitations\n\n* There's only support for BlockingConnection adapter since this is the main adapter used in production.\n* Threaded Receiver class is not thread-safe, will be added using an internal instance of Queue() to address that issue.\n* This packages does not support the inheritance of Receiver and Dispatcher in the same child class.\n\n# License\n\nGNU GPLv3\n\nPermissions of this strong copyleft license are conditioned on making available complete source code of licensed works and modifications, which include larger works using a licensed work, under the same license. Copyright and license notices must be preserved. Contributors provide an express grant of patent rights.\n\n\n\n", "description_content_type": "text/markdown", "docs_url": null, "download_url": "https://gitlab.com/avanti-open-source/pyamqp.git", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://gitlab.com/avanti-open-source/pyamqp", "keywords": "message broker queues amqp processing data", "license": "MIT", "maintainer": "", "maintainer_email": "", "name": "PyAMQP", "package_url": "https://pypi.org/project/PyAMQP/", "platform": "", "project_url": "https://pypi.org/project/PyAMQP/", "project_urls": { "Download": "https://gitlab.com/avanti-open-source/pyamqp.git", "Homepage": "https://gitlab.com/avanti-open-source/pyamqp" }, "release_url": "https://pypi.org/project/PyAMQP/0.0.8.5/", "requires_dist": [ "pika (==0.13)", "pytest" ], "requires_python": ">=3.6.0", "summary": "Python interface for simple usage of AMQP middleware applications.", "version": "0.0.8.5" }, "last_serial": 5816920, "releases": { "0.0.7": [ { "comment_text": "", "digests": { "md5": "4591796ac3e1e9178eb1a1701b36ac6e", "sha256": "1ac7d4f8c1cfb9fa81e9ab98fe5973353d525eaf6325371ed6926cedb94ac17a" }, "downloads": -1, "filename": "PyAMQP-0.0.7-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "4591796ac3e1e9178eb1a1701b36ac6e", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=3.6.0", "size": 7032, "upload_time": "2019-03-01T12:59:08", "url": "https://files.pythonhosted.org/packages/bf/74/39e7963adc19fe610684955808a3306df2d6ce3a647b333d291a3a90dc23/PyAMQP-0.0.7-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "707b8b8912189d51f90d428d7d69ac03", "sha256": "82cf6acd2d1b7068787155840ae0e6cced2199c14f4f44091405445f3d961c16" }, "downloads": -1, "filename": "PyAMQP-0.0.7.tar.gz", "has_sig": false, "md5_digest": "707b8b8912189d51f90d428d7d69ac03", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 6535, "upload_time": "2019-03-01T12:59:09", "url": "https://files.pythonhosted.org/packages/f6/57/b22c050d34a109fe39d87dd1c7ab4459e5ce4369f81f7e623d4c015cbe31/PyAMQP-0.0.7.tar.gz" } ], "0.0.7.1": [ { "comment_text": "", "digests": { "md5": "6a56ba3dc9d0d49dc7c999be1ecea5e4", "sha256": "c9aececf903e72085992a0fd553a4489d49b6c1d3d43122255e164ecb2d43961" }, "downloads": -1, "filename": "PyAMQP-0.0.7.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "6a56ba3dc9d0d49dc7c999be1ecea5e4", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=3.6.0", "size": 7071, "upload_time": "2019-03-01T13:02:45", "url": "https://files.pythonhosted.org/packages/e5/4f/3b4075c2acad45b6c1611fa87a653a5e6ce382346870acdb68c0ca5aa6ce/PyAMQP-0.0.7.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "c901f881c21919d8961cf1a999bf1980", "sha256": "8be4639242a99a1c9e867725656b45cb192f2670afe25d47ae670ff54c1e4cd5" }, "downloads": -1, "filename": "PyAMQP-0.0.7.1.tar.gz", "has_sig": false, "md5_digest": "c901f881c21919d8961cf1a999bf1980", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 6551, "upload_time": "2019-03-01T13:02:47", "url": "https://files.pythonhosted.org/packages/95/c5/7598ac68858a24383772a9ae5634ad4612a6d291520ab29cf42ddb49cebb/PyAMQP-0.0.7.1.tar.gz" } ], "0.0.7.2": [ { "comment_text": "", "digests": { "md5": "92465fdcdbecce930144e937b4e52d8f", "sha256": "495572e78e641618dd361c6238dfaafc76664a93c9ce1acd01798f882e465664" }, "downloads": -1, "filename": "PyAMQP-0.0.7.2-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "92465fdcdbecce930144e937b4e52d8f", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=3.6.0", "size": 9324, "upload_time": "2019-04-30T16:22:01", "url": "https://files.pythonhosted.org/packages/f8/bf/6994ca9b8dced03c654bb5cf829c4b18316842c3f0654e04d656ba9f1913/PyAMQP-0.0.7.2-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "ece65a93db9671ff389714163b070460", "sha256": "8778d8dff27af030ccfceeb9f88960f59fc28cf0ba2a01f3059253089b5feb0b" }, "downloads": -1, "filename": "PyAMQP-0.0.7.2.tar.gz", "has_sig": false, "md5_digest": "ece65a93db9671ff389714163b070460", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 6508, "upload_time": "2019-04-30T16:22:04", "url": "https://files.pythonhosted.org/packages/2f/eb/83663c460db5d24253f25b2f4651ba99675e56d600f716262ea64a4e3491/PyAMQP-0.0.7.2.tar.gz" } ], "0.0.7.3": [ { "comment_text": "", "digests": { "md5": "88090a546ffc9fc411b76a890e12cf72", "sha256": "8c13970c0287a1be41b53af15230311776aca788ccfd7ea13143c40d8fbdaf72" }, "downloads": -1, "filename": "PyAMQP-0.0.7.3-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "88090a546ffc9fc411b76a890e12cf72", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=3.6.0", "size": 7082, "upload_time": "2019-05-15T16:57:32", "url": "https://files.pythonhosted.org/packages/29/7a/65a6b5293c9d3f7fd9ae2cc6042943aca197ae3522f2247e471730af307b/PyAMQP-0.0.7.3-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "d576d7db750594144591287c7554e07b", "sha256": "919e979376ce64ffdd28a9a256922c961c003e1d1d96f9d146a454cb5a8e894b" }, "downloads": -1, "filename": "PyAMQP-0.0.7.3.tar.gz", "has_sig": false, "md5_digest": "d576d7db750594144591287c7554e07b", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 6565, "upload_time": "2019-05-15T16:57:33", "url": "https://files.pythonhosted.org/packages/b9/de/dee4cd8c84849349e8684d0e4fdb1cfc14eb47bf97085414e26721cbe3a7/PyAMQP-0.0.7.3.tar.gz" } ], "0.0.7.7": [ { "comment_text": "", "digests": { "md5": "e1a7f96bbb7f1d92a472809ea2a20b9c", "sha256": "d694c39fdc0c88c60bb444dbca686f4eeaafb2d8c97cc9497541b1840dd494f8" }, "downloads": -1, "filename": "PyAMQP-0.0.7.7-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "e1a7f96bbb7f1d92a472809ea2a20b9c", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=3.6.0", "size": 7091, "upload_time": "2019-06-02T22:17:10", "url": "https://files.pythonhosted.org/packages/d0/5e/186b7069c3e018e877897e58a959f8ba8cfc7cd50f6a8ccafec1a79eed57/PyAMQP-0.0.7.7-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "241b40a9058761750a0e440d575ede34", "sha256": "f8b0b6c29c4e15faeb98581cc7d7dd7e46476c349e828c37836c1b0a6190f3ce" }, "downloads": -1, "filename": "PyAMQP-0.0.7.7.tar.gz", "has_sig": false, "md5_digest": "241b40a9058761750a0e440d575ede34", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 6610, "upload_time": "2019-06-02T22:17:12", "url": "https://files.pythonhosted.org/packages/71/68/ebf95f4e3b7ed5ba2b7a0202b7244c2753f44cc189ea8673f5b8e838c6ce/PyAMQP-0.0.7.7.tar.gz" } ], "0.0.8.1": [ { "comment_text": "", "digests": { "md5": "196f5fafba1b129903e961cd8831d7a4", "sha256": "603b253e7ba2d098cfd4bfd0b886a9317a983d410240530a64c06b008c4fca34" }, "downloads": -1, "filename": "PyAMQP-0.0.8.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "196f5fafba1b129903e961cd8831d7a4", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=3.6.0", "size": 7099, "upload_time": "2019-07-01T17:11:05", "url": "https://files.pythonhosted.org/packages/04/88/a0b24ef006d1770e759ea15f89a1bbc3fe366de557b553c8018a6dc05dac/PyAMQP-0.0.8.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "b74c1512cc883d2aab112fffd1c9a984", "sha256": "e63b525ffde59158d6bf6f1004bdde9066b9f0ecd9f4c9cb938eadbbeb267877" }, "downloads": -1, "filename": "PyAMQP-0.0.8.1.tar.gz", "has_sig": false, "md5_digest": "b74c1512cc883d2aab112fffd1c9a984", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 6616, "upload_time": "2019-07-01T17:11:06", "url": "https://files.pythonhosted.org/packages/82/09/05544f35b2b71a678ab11258ee95e65a88361ff0e7e313d0780355afae84/PyAMQP-0.0.8.1.tar.gz" } ], "0.0.8.4": [ { "comment_text": "", "digests": { "md5": "16545f36a0dc6b52b81140d89d1a09f1", "sha256": "4768e0dd2637b97379d2498f1ad28291a655133809cc82463e8b004453bcb617" }, "downloads": -1, "filename": "PyAMQP-0.0.8.4-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "16545f36a0dc6b52b81140d89d1a09f1", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=3.6.0", "size": 7160, "upload_time": "2019-09-11T21:01:37", "url": "https://files.pythonhosted.org/packages/0f/07/d1bf597346570328c326e692029a6c3203adcc721033e8e92db38b4482ac/PyAMQP-0.0.8.4-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "4dd5be8f63106e542bee21102338c861", "sha256": "fa5d781849d69d77412449f259a644f6769bf702a26c40b364db8ce9df217b62" }, "downloads": -1, "filename": "PyAMQP-0.0.8.4.tar.gz", "has_sig": false, "md5_digest": "4dd5be8f63106e542bee21102338c861", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 6680, "upload_time": "2019-09-11T21:01:39", "url": "https://files.pythonhosted.org/packages/76/fb/ec48f4947c31b01391fad94c0efcb8951ddae521ec9e1304e84b1b29c1f0/PyAMQP-0.0.8.4.tar.gz" } ], "0.0.8.5": [ { "comment_text": "", "digests": { "md5": "cdee2e62273152dcd8c35675b01a4cb2", "sha256": "07598620f979738900be7e9998de3d7cae26ff85c11ea7402003c729e7948fca" }, "downloads": -1, "filename": "PyAMQP-0.0.8.5-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "cdee2e62273152dcd8c35675b01a4cb2", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=3.6.0", "size": 7158, "upload_time": "2019-09-11T21:02:54", "url": "https://files.pythonhosted.org/packages/6b/c0/3d797f66d6ec5309777a1911a9daa2de8ea133a428bf40e16a09dd50d01a/PyAMQP-0.0.8.5-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "481cdf38385e6a8b7f588e3d8756ecaa", "sha256": "c6e78f72c9c690cb6a3c5b13b84effe47272635e8755332ac7165b7c5f6f9698" }, "downloads": -1, "filename": "PyAMQP-0.0.8.5.tar.gz", "has_sig": false, "md5_digest": "481cdf38385e6a8b7f588e3d8756ecaa", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 6679, "upload_time": "2019-09-11T21:02:56", "url": "https://files.pythonhosted.org/packages/ed/c8/b132d746db93ade14ddbb159cd98f093712eac21d4c3dab8605de9d62e0b/PyAMQP-0.0.8.5.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "cdee2e62273152dcd8c35675b01a4cb2", "sha256": "07598620f979738900be7e9998de3d7cae26ff85c11ea7402003c729e7948fca" }, "downloads": -1, "filename": "PyAMQP-0.0.8.5-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "cdee2e62273152dcd8c35675b01a4cb2", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=3.6.0", "size": 7158, "upload_time": "2019-09-11T21:02:54", "url": "https://files.pythonhosted.org/packages/6b/c0/3d797f66d6ec5309777a1911a9daa2de8ea133a428bf40e16a09dd50d01a/PyAMQP-0.0.8.5-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "481cdf38385e6a8b7f588e3d8756ecaa", "sha256": "c6e78f72c9c690cb6a3c5b13b84effe47272635e8755332ac7165b7c5f6f9698" }, "downloads": -1, "filename": "PyAMQP-0.0.8.5.tar.gz", "has_sig": false, "md5_digest": "481cdf38385e6a8b7f588e3d8756ecaa", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 6679, "upload_time": "2019-09-11T21:02:56", "url": "https://files.pythonhosted.org/packages/ed/c8/b132d746db93ade14ddbb159cd98f093712eac21d4c3dab8605de9d62e0b/PyAMQP-0.0.8.5.tar.gz" } ] }