{ "info": { "author": "", "author_email": "", "bugtrack_url": null, "classifiers": [], "description": "# aioamqp-consumer-best\n\n[![PyPI version](https://badge.fury.io/py/aioamqp-consumer-best.svg)](https://pypi.org/project/aioamqp-consumer-best/) [![Build Status](https://travis-ci.org/tkukushkin/aioamqp-consumer-best.svg?branch=master)](https://travis-ci.org/tkukushkin/aioamqp-consumer-best) [![codecov](https://codecov.io/gh/tkukushkin/aioamqp-consumer-best/branch/master/graph/badge.svg)](https://codecov.io/gh/tkukushkin/aioamqp-consumer-best)\n\n## Usage\n\n```python\nimport asyncio\nfrom typing import List\n\nfrom aioamqp_consumer_best import (\n ConnectionParams,\n Consumer,\n Exchange,\n Message,\n ProcessBulk,\n Queue,\n QueueBinding,\n ToBulks,\n load_json,\n)\n\n\nasync def callback(messages: List[Message]) -> None:\n print(messages)\n\n\nconsumer = Consumer(\n middleware=(\n load_json\n | ToBulks(max_bulk_size=10, bulk_timeout=3.0)\n | ProcessBulk(callback)\n ),\n prefetch_count=10,\n queue=Queue(\n name='test-queue',\n bindings=[\n QueueBinding(\n exchange=Exchange('test-exchange'),\n routing_key='test-routing-key',\n ),\n ],\n ),\n connection_params=[ # Round robin\n ConnectionParams(),\n ConnectionParams.from_string('amqp://user@rmq-host:5672/'),\n ],\n)\n\nasyncio.get_event_loop().run_until_complete(consumer.start())\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": "", "keywords": "", "license": "", "maintainer": "", "maintainer_email": "", "name": "aioamqp-consumer-best", "package_url": "https://pypi.org/project/aioamqp-consumer-best/", "platform": "", "project_url": "https://pypi.org/project/aioamqp-consumer-best/", "project_urls": null, "release_url": "https://pypi.org/project/aioamqp-consumer-best/1.1.2/", "requires_dist": [ "aioamqp", "aionursery (<0.3.0)", "dataclasses", "mypy (==0.600); extra == 'test'", "pycodestyle; extra == 'test'", "pylint; extra == 'test'", "pytest; extra == 'test'", "pytest-asyncio; extra == 'test'", "pytest-cov; extra == 'test'", "pytest-mock; extra == 'test'" ], "requires_python": "", "summary": "", "version": "1.1.2" }, "last_serial": 4435215, "releases": { "1.0.0": [ { "comment_text": "", "digests": { "md5": "9a625d935e1bb35faa93be2cb805f40c", "sha256": "716549b33fbbec832649292fdde8c98925d91ba3ac41c91250f0a284272a8753" }, "downloads": -1, "filename": "aioamqp_consumer_best-1.0.0-py3-none-any.whl", "has_sig": false, "md5_digest": "9a625d935e1bb35faa93be2cb805f40c", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 8754, "upload_time": "2018-08-11T06:47:53", "url": "https://files.pythonhosted.org/packages/e5/9b/06a4c2837aecc57fb91f4b5b33c3d2738b0efb86698d35bdbb36bdeff04d/aioamqp_consumer_best-1.0.0-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "9ca1eb0910d13939f9e341e34bf748f0", "sha256": "688c3f938847005ad962852dbc38c7dc482df51b3bf4aad9f4d78ff5b948d497" }, "downloads": -1, "filename": "aioamqp-consumer-best-1.0.0.tar.gz", "has_sig": false, "md5_digest": "9ca1eb0910d13939f9e341e34bf748f0", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5467, "upload_time": "2018-08-11T06:47:54", "url": "https://files.pythonhosted.org/packages/88/65/27f07adefe06b0d1a4cc05d90e5cf83d5ed4e49b7f6577d2cab6a763f4b9/aioamqp-consumer-best-1.0.0.tar.gz" } ], "1.0.1": [ { "comment_text": "", "digests": { "md5": "d60fc67ade483616a2b284795c63b422", "sha256": "1e66fff51d1ca87ee283803cf0492f0d716ae599d7bc2c4fcc6030ffb67757ad" }, "downloads": -1, "filename": "aioamqp_consumer_best-1.0.1-py3-none-any.whl", "has_sig": false, "md5_digest": "d60fc67ade483616a2b284795c63b422", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 8358, "upload_time": "2018-08-12T10:24:11", "url": "https://files.pythonhosted.org/packages/84/1a/30628ed130eb3e2fc273f17cf7554dcaf09e2fb7aeac25c18666ac6820c9/aioamqp_consumer_best-1.0.1-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "c5c9525844b19446fd3afc0b29873771", "sha256": "e6b3f3dd6ac117812b40d5f8146c1ce9630f8bdb05d661112d5a0fbcf0ec2088" }, "downloads": -1, "filename": "aioamqp-consumer-best-1.0.1.tar.gz", "has_sig": false, "md5_digest": "c5c9525844b19446fd3afc0b29873771", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5724, "upload_time": "2018-08-12T10:24:13", "url": "https://files.pythonhosted.org/packages/48/96/c25352c2eaf8f6158df3afb0925efd2b2f9e806e833108315474e235f4b3/aioamqp-consumer-best-1.0.1.tar.gz" } ], "1.0.2": [ { "comment_text": "", "digests": { "md5": "05935bb0078baac56628a06e36679e1f", "sha256": "5ce6bd80d593300a02fcd8fa968f9c3882f5427103ec4ffe7a9147f0837523fa" }, "downloads": -1, "filename": "aioamqp_consumer_best-1.0.2-py3-none-any.whl", "has_sig": false, "md5_digest": "05935bb0078baac56628a06e36679e1f", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 8321, "upload_time": "2018-08-12T19:46:19", "url": "https://files.pythonhosted.org/packages/45/48/10ad4b5fc702965d820d4b34d32a842b96e994d296ad543444d80ef18aab/aioamqp_consumer_best-1.0.2-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "ce30aa11b4f423ee6918159807428ca3", "sha256": "de0daa694817852de22c948213b9908cd85aebcb3aeeb16c2a14cd317e77bd0c" }, "downloads": -1, "filename": "aioamqp-consumer-best-1.0.2.tar.gz", "has_sig": false, "md5_digest": "ce30aa11b4f423ee6918159807428ca3", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5686, "upload_time": "2018-08-12T19:46:20", "url": "https://files.pythonhosted.org/packages/79/8b/f14b827c4c60d86190804b1621aa19051bdc61ea2eb0e4955a894e8f0529/aioamqp-consumer-best-1.0.2.tar.gz" } ], "1.1.0": [ { "comment_text": "", "digests": { "md5": "7146241ef5c858d800daa2779099d8f0", "sha256": "84b044ad20f8d73aead0fc267bed4d1f0f47f0667872c1cae2bbfe10f6e5a4c6" }, "downloads": -1, "filename": "aioamqp_consumer_best-1.1.0-py3-none-any.whl", "has_sig": false, "md5_digest": "7146241ef5c858d800daa2779099d8f0", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 8720, "upload_time": "2018-10-23T18:58:53", "url": "https://files.pythonhosted.org/packages/54/a1/72a23a8981a993f62f60e9f7cd8c1eb2644dc8024bb39d93f5ac13d3af84/aioamqp_consumer_best-1.1.0-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "0c6df2c2ad3701182781f875b4bf30ea", "sha256": "623aa48df78e975fc6c1bde4b5a187d77541ed9de659a5514f6c4ba26a0c975a" }, "downloads": -1, "filename": "aioamqp-consumer-best-1.1.0.tar.gz", "has_sig": false, "md5_digest": "0c6df2c2ad3701182781f875b4bf30ea", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5830, "upload_time": "2018-10-23T18:58:55", "url": "https://files.pythonhosted.org/packages/a2/74/191a63ea6ddff28c676c881a3d78faca45fcb45bfdc0ee68db7823e38f63/aioamqp-consumer-best-1.1.0.tar.gz" } ], "1.1.1": [ { "comment_text": "", "digests": { "md5": "54de8cafea047668dbe0be52be17f1dd", "sha256": "a4b8ef7d544227041b42ffc0c49b0f1cb34c8cb16231a9f2e331ccca805f7e56" }, "downloads": -1, "filename": "aioamqp_consumer_best-1.1.1-py3-none-any.whl", "has_sig": false, "md5_digest": "54de8cafea047668dbe0be52be17f1dd", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 9299, "upload_time": "2018-10-23T19:15:09", "url": "https://files.pythonhosted.org/packages/53/55/10958c912fc2259da4a32c208b15dcb3daea5934bb558ded6fa94b7e91e4/aioamqp_consumer_best-1.1.1-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "c211dbdb62cab1c536a9af2a5ca65d45", "sha256": "dda6904c9f7ee4219f924027c166ec63850f71806bd5800378949acfb1cc5ba8" }, "downloads": -1, "filename": "aioamqp-consumer-best-1.1.1.tar.gz", "has_sig": false, "md5_digest": "c211dbdb62cab1c536a9af2a5ca65d45", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 6164, "upload_time": "2018-10-23T19:15:10", "url": "https://files.pythonhosted.org/packages/58/bd/0f5595bc4e97dafb76cfd121e59231c37ef450f3b23fc2952086b931360a/aioamqp-consumer-best-1.1.1.tar.gz" } ], "1.1.2": [ { "comment_text": "", "digests": { "md5": "f2c027c60d31721401446d1024866c88", "sha256": "8f3eaf38b4fd072a463480192709eec9586a6c701083fe86810fbf837de3be5b" }, "downloads": -1, "filename": "aioamqp_consumer_best-1.1.2-py3-none-any.whl", "has_sig": false, "md5_digest": "f2c027c60d31721401446d1024866c88", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 9299, "upload_time": "2018-10-31T10:18:03", "url": "https://files.pythonhosted.org/packages/4c/f8/f0e6f71a2549b006a3dd58182caec153ba876878f71e01d324b2930737b0/aioamqp_consumer_best-1.1.2-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "aa1c5d26206f7d3c98892e49dfb28ea0", "sha256": "465c9d300a32b8d2b7fdea5ec786c8b314998c65051e7d0c9f3c0ce33c42316a" }, "downloads": -1, "filename": "aioamqp-consumer-best-1.1.2.tar.gz", "has_sig": false, "md5_digest": "aa1c5d26206f7d3c98892e49dfb28ea0", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 6172, "upload_time": "2018-10-31T10:18:06", "url": "https://files.pythonhosted.org/packages/eb/0a/33816c13daacfafd16252d6be8493af4f290fe8bd0a95988f03fba5660ca/aioamqp-consumer-best-1.1.2.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "f2c027c60d31721401446d1024866c88", "sha256": "8f3eaf38b4fd072a463480192709eec9586a6c701083fe86810fbf837de3be5b" }, "downloads": -1, "filename": "aioamqp_consumer_best-1.1.2-py3-none-any.whl", "has_sig": false, "md5_digest": "f2c027c60d31721401446d1024866c88", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 9299, "upload_time": "2018-10-31T10:18:03", "url": "https://files.pythonhosted.org/packages/4c/f8/f0e6f71a2549b006a3dd58182caec153ba876878f71e01d324b2930737b0/aioamqp_consumer_best-1.1.2-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "aa1c5d26206f7d3c98892e49dfb28ea0", "sha256": "465c9d300a32b8d2b7fdea5ec786c8b314998c65051e7d0c9f3c0ce33c42316a" }, "downloads": -1, "filename": "aioamqp-consumer-best-1.1.2.tar.gz", "has_sig": false, "md5_digest": "aa1c5d26206f7d3c98892e49dfb28ea0", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 6172, "upload_time": "2018-10-31T10:18:06", "url": "https://files.pythonhosted.org/packages/eb/0a/33816c13daacfafd16252d6be8493af4f290fe8bd0a95988f03fba5660ca/aioamqp-consumer-best-1.1.2.tar.gz" } ] }