{ "info": { "author": "NSO / AURA", "author_email": "\"swiant@nso.edu\"", "bugtrack_url": null, "classifiers": [ "Programming Language :: Python", "Programming Language :: Python :: 3", "Programming Language :: Python :: 3.7" ], "description": "talus\n=========\n\n|codecov|\n\ntalus (noun) - ta\u00b7\u200blus | \u02c8t\u0101-l\u0259s: a slope formed especially by an accumulation of rock debris; Occasional habitat of the pika.\n\nA wrapper for connecting to RabbitMQ which constrains clients to a single purpose channel (producer or consumer) with healing for intermittent connectivity.\n\nFeatures\n--------\n\n- Guided separation of connections for producers and consumers\n\n- Re-establish connections to the server when lost\n\n- Constrained interface to support simple produce / consume use cases for direct exchanges\n\nInstallation\n------------\n\n.. code:: bash\n\n pip install talus\n\nExamples\n--------\n**Consumer with defaults for connection and retry**\n\n.. code:: python\n\n with DurableBlockingConsumerWrapper(consumer_queue='queue_name') as consumer:\n for method, properties, body in consumer.consume_generator(auto_ack=True):\n pass # DO Something with the message\n\n**Consumer specifying connection and retry data**\n\n.. code:: python\n\n with DurableBlockingConsumerWrapper(consumer_queue='queue_name',\n rabbitmq_host=\"localhost\",\n rabbitmq_port5672,\n rabbitmq_user='guest',\n rabbitmq_pass='guest',\n retry_delay=1,\n retry_backoff=2,\n retry_jitter=(1, 10),\n retry_max_delay=300,\n prefetch_count=1,\n connection_name='consumer connection') as consumer:\n for method, properties, body in consumer.consume_generator(auto_ack=True):\n pass # DO Something with the message\n\n**Producer with defaults for connection and retry**\n\n.. code:: python\n\n with DurableBlockingProducerWrapper(producer_queue_bindings=[{\"routing_key\": \"test.m\", \"bound_queue\": \"test.q\"},],\n publish_exchange='amq.direct') as producer:\n producer.post('test.m', {'key': 'value'})\n\n.. |codecov| image:: https://codecov.io/bb/dkistdc/interservice-bus-adapter/branch/master/graph/badge.svg\n :target: https://codecov.io/bb/dkistdc/interservice-bus-adapter", "description_content_type": "", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://bitbucket.org/dkistdc/interservice-bus-adapter/src/master/", "keywords": "", "license": "MIT", "maintainer": "", "maintainer_email": "", "name": "talus", "package_url": "https://pypi.org/project/talus/", "platform": "", "project_url": "https://pypi.org/project/talus/", "project_urls": { "Homepage": "https://bitbucket.org/dkistdc/interservice-bus-adapter/src/master/" }, "release_url": "https://pypi.org/project/talus/0.1.0/", "requires_dist": null, "requires_python": ">=3.6", "summary": "A wrapper for connecting to RabbitMQ which constrains clients to a single purpose channel (producer or consumer) with healing for intermittent connectivity.", "version": "0.1.0" }, "last_serial": 5961924, "releases": { "0.0.1": [ { "comment_text": "", "digests": { "md5": "2604e153cb49e15777ee8f761f6ddcbc", "sha256": "1d1ee2bf0720a05e6ec6c3de7f74602277ecfc478692fb2126c52cd5cfe065c8" }, "downloads": -1, "filename": "talus-0.0.1.tar.gz", "has_sig": false, "md5_digest": "2604e153cb49e15777ee8f761f6ddcbc", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6", "size": 10047, "upload_time": "2019-10-11T18:05:58", "url": "https://files.pythonhosted.org/packages/66/00/649e79754825d6fd8831f3d39adb34050ac43a32a4b95f553ab731585734/talus-0.0.1.tar.gz" } ], "0.0.2": [ { "comment_text": "", "digests": { "md5": "0f2f0de48f66b6c85ba42da98d9148e9", "sha256": "3f2eb1577a80387022fcb2e8b27c5e7aaeca64cd4f3d9afad4d438d5de6dd08c" }, "downloads": -1, "filename": "talus-0.0.2.tar.gz", "has_sig": false, "md5_digest": "0f2f0de48f66b6c85ba42da98d9148e9", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6", "size": 10046, "upload_time": "2019-10-11T18:16:09", "url": "https://files.pythonhosted.org/packages/7f/f6/db1a11107d43824cc093ee277279ffb8db2a4fee3c9cdf196e4423c8668f/talus-0.0.2.tar.gz" } ], "0.0.2rc1": [ { "comment_text": "", "digests": { "md5": "d335207bf473a59ac71db6953c2921a1", "sha256": "023fe29543e2d61503f8a874ae0952c7e2351acdc0c4a722b73844d243e1f8f6" }, "downloads": -1, "filename": "talus-0.0.2rc1.tar.gz", "has_sig": false, "md5_digest": "d335207bf473a59ac71db6953c2921a1", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6", "size": 10051, "upload_time": "2019-10-11T18:14:23", "url": "https://files.pythonhosted.org/packages/dc/52/7c95a9ce23d5a22cde015d7a5b5d4cddbcb12516487da9ac2992851c9645/talus-0.0.2rc1.tar.gz" } ], "0.1.0": [ { "comment_text": "", "digests": { "md5": "74192c97226260be83afcdf6c8fca42a", "sha256": "e77ec7be1c94596c1b60b55b4518c77064b9e67acd4029f100a77f0af54d3152" }, "downloads": -1, "filename": "talus-0.1.0.tar.gz", "has_sig": false, "md5_digest": "74192c97226260be83afcdf6c8fca42a", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6", "size": 10049, "upload_time": "2019-10-11T20:38:09", "url": "https://files.pythonhosted.org/packages/a3/4f/9b8c0d8e8d4febf37ea3429ccb707a55f94ae17b36d1b01fbb0ce0a826f6/talus-0.1.0.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "74192c97226260be83afcdf6c8fca42a", "sha256": "e77ec7be1c94596c1b60b55b4518c77064b9e67acd4029f100a77f0af54d3152" }, "downloads": -1, "filename": "talus-0.1.0.tar.gz", "has_sig": false, "md5_digest": "74192c97226260be83afcdf6c8fca42a", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6", "size": 10049, "upload_time": "2019-10-11T20:38:09", "url": "https://files.pythonhosted.org/packages/a3/4f/9b8c0d8e8d4febf37ea3429ccb707a55f94ae17b36d1b01fbb0ce0a826f6/talus-0.1.0.tar.gz" } ] }