{
    "info": {
        "author": "OCEAN S.A.",
        "author_email": "osf@ocean.io",
        "bugtrack_url": null,
        "classifiers": [
            "Development Status :: 5 - Production/Stable",
            "Intended Audience :: Developers",
            "License :: OSI Approved :: MIT License",
            "Operating System :: MacOS :: MacOS X",
            "Operating System :: Microsoft :: Windows",
            "Operating System :: POSIX",
            "Programming Language :: Python",
            "Programming Language :: Python :: 3",
            "Programming Language :: Python :: 3.5",
            "Programming Language :: Python :: 3.6"
        ],
        "description": "aioamqp_consumer\n================\n\n:info: Consumer/producer like library built over amqp (aioamqp)\n\n.. image:: https://img.shields.io/travis/aio-libs/aioamqp_consumer.svg\n    :target: https://travis-ci.org/aio-libs/aioamqp_consumer\n\n.. image:: https://img.shields.io/pypi/v/aioamqp_consumer.svg\n    :target: https://pypi.python.org/pypi/aioamqp_consumer\n\nInstallation\n------------\n\n.. code-block:: shell\n\n    pip install aioamqp_consumer\n\nUsage\n-----\n\n.. code-block:: python\n\n    import asyncio\n    from functools import partial\n\n    from aioamqp_consumer import Consumer, Producer\n\n\n    async def task(payload, options, sleep=0, *, loop):\n        await asyncio.sleep(sleep, loop=loop)\n        print(payload)\n\n\n    async def main(*, loop):\n        amqp_url = 'amqp://guest:guest@127.0.0.1:5672//'\n        amqp_queue = 'your-queue-here'\n        queue_kwargs = {\n            'durable': True,\n        }\n        amqp_kwargs = {}  # https://aioamqp.readthedocs.io/en/latest/api.html#aioamqp.connect\n\n        async with Producer(amqp_url, amqp_kwargs=amqp_kwargs, loop=loop) as producer:\n            for _ in range(5):\n                await producer.publish(\n                    b'hello',\n                    amqp_queue,\n                    queue_kwargs=queue_kwargs,\n                )\n\n        consumer = Consumer(\n            amqp_url,\n            partial(task, loop=loop, sleep=1),\n            amqp_queue,\n            queue_kwargs=queue_kwargs,\n            amqp_kwargs=amqp_kwargs,\n            loop=loop,\n        )\n        await consumer.scale(20)  # scale up to 20 background coroutines\n        await consumer.scale(5)  # downscale to 5 background coroutines\n        await consumer.join()  # wait for rabbitmq queue is empty and all local messages are processed\n        consumer.close()\n        await consumer.wait_closed()\n\n    loop = asyncio.get_event_loop()\n    loop.run_until_complete(main(loop=loop))\n    loop.close()\n",
        "description_content_type": "",
        "docs_url": null,
        "download_url": "",
        "downloads": {
            "last_day": -1,
            "last_month": -1,
            "last_week": -1
        },
        "home_page": "https://github.com/wikibusiness/aioamqp_consumer",
        "keywords": "aioamqp",
        "license": "",
        "maintainer": "",
        "maintainer_email": "",
        "name": "aioamqp_consumer",
        "package_url": "https://pypi.org/project/aioamqp_consumer/",
        "platform": "",
        "project_url": "https://pypi.org/project/aioamqp_consumer/",
        "project_urls": {
            "Homepage": "https://github.com/wikibusiness/aioamqp_consumer"
        },
        "release_url": "https://pypi.org/project/aioamqp_consumer/0.1.3/",
        "requires_dist": null,
        "requires_python": "",
        "summary": "Consumer/producer like library built over amqp (aioamqp)",
        "version": "0.1.3"
    },
    "last_serial": 4292443,
    "releases": {
        "0.0.1": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "904aea1b2014e09a55ea098ef25bca35",
                    "sha256": "9b5c402440ce0a07e9c021b661bcea3855007429f72e4e8bab58969e58ded426"
                },
                "downloads": -1,
                "filename": "aioamqp_consumer-0.0.1.tar.gz",
                "has_sig": false,
                "md5_digest": "904aea1b2014e09a55ea098ef25bca35",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 7459,
                "upload_time": "2017-07-05T10:44:14",
                "url": "https://files.pythonhosted.org/packages/01/9b/11c6339dd3965b04ac4700bb4ab8665ae67ac7b6db636f25adc787be3420/aioamqp_consumer-0.0.1.tar.gz"
            }
        ],
        "0.1.0": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "db01ea9aa378e8d3740065a193895c29",
                    "sha256": "6035345e9e82e1999d34771cf9ebeef838dcdf9df372f68567033d0c3d642482"
                },
                "downloads": -1,
                "filename": "aioamqp_consumer-0.1.0.tar.gz",
                "has_sig": false,
                "md5_digest": "db01ea9aa378e8d3740065a193895c29",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 8234,
                "upload_time": "2017-11-21T18:48:20",
                "url": "https://files.pythonhosted.org/packages/9c/d3/de2d056b34f2888675b7c70e566fc79eecfcde7fffc2a020da2dd598e666/aioamqp_consumer-0.1.0.tar.gz"
            }
        ],
        "0.1.1": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "c974c0628abd4756e69ab285df6934fc",
                    "sha256": "e312a959078ef7ec15b4bd9c108616ecc4aec21bbdf843196cabc45d83b85f4d"
                },
                "downloads": -1,
                "filename": "aioamqp_consumer-0.1.1.tar.gz",
                "has_sig": false,
                "md5_digest": "c974c0628abd4756e69ab285df6934fc",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 8281,
                "upload_time": "2017-11-21T21:21:36",
                "url": "https://files.pythonhosted.org/packages/46/88/73f5adfc75542e34de72dd3c539c8299034c1fd808384eb23aed90f2b58e/aioamqp_consumer-0.1.1.tar.gz"
            }
        ],
        "0.1.2": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "02b34e4e7a7310966c259e9e1dc321ae",
                    "sha256": "e661ce8857b91b99ff38e7a74b516111b8dd898676785d7153ea63956204aaf4"
                },
                "downloads": -1,
                "filename": "aioamqp_consumer-0.1.2.tar.gz",
                "has_sig": false,
                "md5_digest": "02b34e4e7a7310966c259e9e1dc321ae",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 8301,
                "upload_time": "2017-11-22T08:36:56",
                "url": "https://files.pythonhosted.org/packages/e1/b8/f029b20c9545e786d0ed78f4cfe5872f3621d94e73f87685b256c03768b8/aioamqp_consumer-0.1.2.tar.gz"
            }
        ],
        "0.1.3": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "7e0795dc65e296c3c89caa72181d5598",
                    "sha256": "8061be66eb870561df5f2639b43b975fe50f645e01ebcb16bc14eb171b0cd6f2"
                },
                "downloads": -1,
                "filename": "aioamqp_consumer-0.1.3.tar.gz",
                "has_sig": false,
                "md5_digest": "7e0795dc65e296c3c89caa72181d5598",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 7816,
                "upload_time": "2018-09-20T12:18:00",
                "url": "https://files.pythonhosted.org/packages/f9/17/84cf1e39b7287065d5c95e0bd50c0f75f5069bcc5da27421194ea1d7fceb/aioamqp_consumer-0.1.3.tar.gz"
            }
        ]
    },
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "md5": "7e0795dc65e296c3c89caa72181d5598",
                "sha256": "8061be66eb870561df5f2639b43b975fe50f645e01ebcb16bc14eb171b0cd6f2"
            },
            "downloads": -1,
            "filename": "aioamqp_consumer-0.1.3.tar.gz",
            "has_sig": false,
            "md5_digest": "7e0795dc65e296c3c89caa72181d5598",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": null,
            "size": 7816,
            "upload_time": "2018-09-20T12:18:00",
            "url": "https://files.pythonhosted.org/packages/f9/17/84cf1e39b7287065d5c95e0bd50c0f75f5069bcc5da27421194ea1d7fceb/aioamqp_consumer-0.1.3.tar.gz"
        }
    ]
}