{ "info": { "author": "chandan mishra", "author_email": "chandan.mishra@greendeck.co", "bugtrack_url": null, "classifiers": [ "License :: OSI Approved :: MIT License", "Operating System :: OS Independent", "Programming Language :: Python :: 3" ], "description": "GD-rabbitMQ\n---\n**Right now this package is only for ```greendeck's``` internal use. This will help to publish and consume messages with your rabbitMQ**\n\n![Greendeck](https://greendeck-cdn.s3.ap-south-1.amazonaws.com/dumps/gd_transparent_blue_bg.png) ![RabbitMQ](https://greendeck-cdn.s3.ap-south-1.amazonaws.com/dumps/rabbitmq.png)\n### Install from pip\nhttps://pypi.org/project/greendeck-rabbitmq/\n\n```pip install greendeck-rabbitmq```\n\nRead details about all default parameters and core functions here in RabbitMQ official website. (https://www.rabbitmq.com)\n\n\n### How to use ?\n##### import the library\n```python\nimport greendeck_rabbitmq\n```\n\n##### import ```RabbitMQ``` class\n```python\nfrom greendeck_rabbitmq import RabbitMQ\n```\n\n##### initialize ```RabbitMQ``` client connection\n\nHere default values of some arguments are \n* RMQ_PORT=5672\n* RMQ_VHOST='/'\n* username=Null\n* password=Null\n\n\n```python\nfrom greendeck_rabbitmq import RabbitMQ\n\n# declare variables\nRMQ_HOST = # RabbitMQ host address\nRMQ_PORT = # RabbitMQ port\nRMQ_VHOST = # RabbitMQ virtual host \nusername = # RabbitMQ username\npassword = # RabbitMQ password\n\n```Here default values are RMQ_PORT=5672, RMQ_VHOST='/', username=Null, password=Null```\n\nrabbitmq_client = RabbitMQ(RMQ_HOST, RMQ_PORT, RMQ_VHOST = RMQ_VHOST, username = username, password = password)\n\n```\n\n\n##### close ```RabbitMQ``` client connection\n```python\nrabbitmq_client.rabbitmq_close_connection()\n```\n##### check size of a rabbitmq queue\n```python\n\nqueue = \"test_library\"\nprint(rabbitmq_client.size(queue))\n```\n##### check if a size of queue is empty or not\n```python\n\nqueue = \"test_library\"\n\nprint(rabbitmq_client.is_empty(queue))\n```\n\n##### consume all messages of a queue\n```python\nqueue = \"test_library\"\nrabbitmq_client.rabbitmq_get_all(queue)\n\n```\n\n##### single message producer\n\nHere default parameters and their values are:\n* exchange=\"\"\n* delivery_mode=2\n* mode=\"single\"\n\n```python\nmessage = \"hello world\"\nqueue = \"test_library\"\nrouting_key = \"test_library\"\nexchange = ''\ndelivery_mode = 2\nmode = \"single\"\n\n```The routing key is a message attribute. The exchange might look at this key when deciding how to route the message to queues (depending on exchange type). ```\n``` delivery mode = 1 means non persistent, and delivery mode = 2 means persistent```\n\n```available modes are 'single' & 'multi' and in 'multi' mode it expects message as list of messages\n\nrabbitmq_client.rabbitmq_publisher(message, queue, routing_key, exchange = exchange, delivery_mode = delivery_mode, mode = mode)\nrabbitmq_client.rabbitmq_close_connection()\n```\n\n##### multi messages producer\n\nHere default parameters and their values are:\n* exchange=\"\"\n* delivery_mode=2\n* mode=\"single\"\n\n```python\nmessage = [\"hello world\"] * 100 #list of messages\nqueue = \"test_library\"\nrouting_key = \"test_library\"\nexchange = ''\ndelivery_mode = 2\nmode = \"multi\"\n\nrabbitmq_client.rabbitmq_publisher(message, queue, routing_key, exchange = exchange, delivery_mode = delivery_mode, mode = mode)\nrabbitmq_client.rabbitmq_close_connection()\n```\n\n##### messages consumer\nHere default parameters and their values are:\n* size=1\n\n```python\nqueue = \"test_library\"\nsize = 1 # mention number of required messages\n\nresults = rabbitmq_client.rabbitmq_consumer(queue, size)\nprint(\"number of messages\", len(results))\nrabbitmq_consumer.rabbitmq_close_connection()\n\n```\n\n##### create an exchange\nThis will create an exchange and bind the list of queues to the same exchange.\nDefault arguments and their values are:\n* exchange_type = \"fanout\"\n* routing_key = \"\"\n\n\n```python\nexchange = \"test_exchange\"\nqueues = [\"queue1\", \"queue2\", \"queue3\"]\nexchange_type = \"fanout\" # for now exchange_type only supports 'fanout'\nrouting_key = \"\" # make sure to keep this one same in your project for easy use\n\n```Here default arguments are exchange_type=\"fanout\", routing_key=\"\"```\n\nrabbitmq_client.make_rabbitmq_exchange(exchange, queues, exchange_type=exchange_type, routing_key=routing_key)\n\n```\n\n##### produce single message to an exchange\nProduce a single message to an exchange\n\nDefault arguments and their values are:\n* exchange_type = \"fanout\"\n* routing_key = \"\"\n* mode = \"single\"\n\n```python\nexchange = \"test_exchange\"\nmessage = \"hello\" \nexchange_type = \"fanout\"\nrouting_key = \"\"\nmode = \"single\"\n\n``` Here avilable modes are single or multi . When it is in multi mode it expects type of message field as list```\n\nrabbitmq_client.rabbitmq_exchange_publisher(exchange ,message, exchange_type=exchange_type, routing_key=routing_key,\n mode=mode)\n\n```\n\n##### produce single message to an exchange\nProduce a single message to an exchange\n\nDefault arguments and their values are:\n* exchange_type = \"fanout\"\n* routing_key = \"\"\n* mode = \"single\"\n\n```python\nexchange = \"test_exchange\"\nmessage = [\"hello1\", \"hello2\", \"hello3\"] \nexchange_type = \"fanout\"\nrouting_key = \"\"\nmode = \"multi\"\n\n``` Here avilable modes are single or multi . When it is in single mode it expects type of message field as a string```\n\nrabbitmq_client.rabbitmq_exchange_publisher(exchange ,message, exchange_type=exchange_type, routing_key=routing_key,\n mode=mode)\n\n```\n\n---\nHow to build your pip package\n\n* open an account here https://pypi.org/\n\nIn the parent directory\n* ```python setup.py sdist bdist_wheel```\n* ```twine upload dist/*```\n\nUpdate your package\n* ```python setup.py sdist```\n* ```twine upload dist/*```\n\nreferences\n* https://medium.com/small-things-about-python/lets-talk-about-python-packaging-6d84b81f1bb5\n* https://packaging.python.org/tutorials/packaging-projects/RabbitMQ\n\n# Thank You", "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/IIITian-Chandan/greendeck-rabbitmq.git", "keywords": "", "license": "", "maintainer": "", "maintainer_email": "", "name": "greendeck-rabbitmq", "package_url": "https://pypi.org/project/greendeck-rabbitmq/", "platform": "", "project_url": "https://pypi.org/project/greendeck-rabbitmq/", "project_urls": { "Homepage": "https://github.com/IIITian-Chandan/greendeck-rabbitmq.git" }, "release_url": "https://pypi.org/project/greendeck-rabbitmq/1.0.16/", "requires_dist": null, "requires_python": "", "summary": "Greendeck rabbitmq package", "version": "1.0.16", "yanked": false, "yanked_reason": null }, "last_serial": 6018499, "releases": { "1.0.10": [ { "comment_text": "", "digests": { "md5": "8880b6b2182efbc89b935b6ec71bda78", "sha256": "bdf3ae8972350d4fd941ae9116152a50b69f842da62b4da84586fccd5c400e73" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.10.tar.gz", "has_sig": false, "md5_digest": "8880b6b2182efbc89b935b6ec71bda78", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3774, "upload_time": "2019-08-12T09:18:50", "upload_time_iso_8601": "2019-08-12T09:18:50.458710Z", "url": "https://files.pythonhosted.org/packages/9a/4e/c05c586b74a4524e26ade3f8edaef6de7db03d4b4ce85f3cc8007b57c3e2/greendeck-rabbitmq-1.0.10.tar.gz", "yanked": false, "yanked_reason": null } ], "1.0.11": [ { "comment_text": "", "digests": { "md5": "3a70e4da39479f38f763325f0c1d6f2d", "sha256": "e35538a1f1528f1516de6c35f647516ed2a7f54a614a7ae0c512f77f4f042729" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.11.tar.gz", "has_sig": false, "md5_digest": "3a70e4da39479f38f763325f0c1d6f2d", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3784, "upload_time": "2019-08-21T06:32:29", "upload_time_iso_8601": "2019-08-21T06:32:29.933701Z", "url": "https://files.pythonhosted.org/packages/a7/26/53cdacb46d1ebae967a29547d9eee5a3e117533ec0f864f20cf4f426cff4/greendeck-rabbitmq-1.0.11.tar.gz", "yanked": false, "yanked_reason": null } ], "1.0.12": [ { "comment_text": "", "digests": { "md5": "f6fc8d1bfd3ab2a0035fac5edf12f0c3", "sha256": "b22652e3160438e3ab12fd799958d101620636e85d51a34c778464f6b36e1d55" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.12.tar.gz", "has_sig": false, "md5_digest": "f6fc8d1bfd3ab2a0035fac5edf12f0c3", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4842, "upload_time": "2019-09-02T13:53:26", "upload_time_iso_8601": "2019-09-02T13:53:26.502805Z", "url": "https://files.pythonhosted.org/packages/da/e9/99186ef23fa276998ffc1063da4a07177e9ba99fd2a5fc300a358a7243a3/greendeck-rabbitmq-1.0.12.tar.gz", "yanked": false, "yanked_reason": null } ], "1.0.13": [ { "comment_text": "", "digests": { "md5": "bc1b0ef38cf5475e27da6f870f848a9e", "sha256": "af7bbd2c9540a5395a35be6519aa1c08d0208eceae3dd1eff97911f6fb4da435" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.13.tar.gz", "has_sig": false, "md5_digest": "bc1b0ef38cf5475e27da6f870f848a9e", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4832, "upload_time": "2019-09-19T07:38:36", "upload_time_iso_8601": "2019-09-19T07:38:36.497818Z", "url": "https://files.pythonhosted.org/packages/c3/c5/70024d8d84ea556d90b89b69db25f4bda91614fa0cf8f4b6d69bd960191f/greendeck-rabbitmq-1.0.13.tar.gz", "yanked": false, "yanked_reason": null } ], "1.0.14": [ { "comment_text": "", "digests": { "md5": "99c96d9072f29c23c9a4a83b959f6691", "sha256": "ad8354c64bc844504d30ec47d333f7d07945b088dbe707db1e39c428f9a22d46" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.14.tar.gz", "has_sig": false, "md5_digest": "99c96d9072f29c23c9a4a83b959f6691", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4839, "upload_time": "2019-10-16T07:25:49", "upload_time_iso_8601": "2019-10-16T07:25:49.825701Z", "url": "https://files.pythonhosted.org/packages/e1/46/b76ba412b685043060015e7f53538c263614019823d91b414e121d861ae6/greendeck-rabbitmq-1.0.14.tar.gz", "yanked": false, "yanked_reason": null } ], "1.0.15": [ { "comment_text": "", "digests": { "md5": "4f8d45947bb07228afb70f5bd5a3df31", "sha256": "f71148a71a63f1c45a1ab39b8482aa8a0d196b8b23ee34c638c7fc7e10aa1bf7" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.15.tar.gz", "has_sig": false, "md5_digest": "4f8d45947bb07228afb70f5bd5a3df31", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4831, "upload_time": "2019-10-16T07:35:51", "upload_time_iso_8601": "2019-10-16T07:35:51.889764Z", "url": "https://files.pythonhosted.org/packages/53/a9/adf400a7e92d42eaeb6e96e9ef8564fcdb6a68ab478dbc9feaaf9e87e99e/greendeck-rabbitmq-1.0.15.tar.gz", "yanked": false, "yanked_reason": null } ], "1.0.16": [ { "comment_text": "", "digests": { "md5": "094ee04f18892caebd980e996d144aa6", "sha256": "3de288c551353164b71215c8ec5ef591be5340cd8d369f355a4915bcce77516b" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.16.tar.gz", "has_sig": false, "md5_digest": "094ee04f18892caebd980e996d144aa6", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4860, "upload_time": "2019-10-23T13:11:35", "upload_time_iso_8601": "2019-10-23T13:11:35.124652Z", "url": "https://files.pythonhosted.org/packages/4a/4c/640bacdc600de43fa82bd79a0ccc677a4e2dbe86f2df6cbf0599464d7dd1/greendeck-rabbitmq-1.0.16.tar.gz", "yanked": false, "yanked_reason": null } ], "1.0.6": [ { "comment_text": "", "digests": { "md5": "c572abd02360ac5b78941f43c8ed9f49", "sha256": "2054be76dd3b820f5f515b5ec8546b9c3b391f6d28e77bb3d823141faf4c8513" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.6.tar.gz", "has_sig": false, "md5_digest": "c572abd02360ac5b78941f43c8ed9f49", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3756, "upload_time": "2019-08-09T10:01:01", "upload_time_iso_8601": "2019-08-09T10:01:01.284897Z", "url": "https://files.pythonhosted.org/packages/3c/01/63234e50b00212a73f8f1cba8a08e2d581ea2d777a7f1c2fc917b1259b06/greendeck-rabbitmq-1.0.6.tar.gz", "yanked": false, "yanked_reason": null } ], "1.0.7": [ { "comment_text": "", "digests": { "md5": "e722daf545db6f2c1c7b8295086414ea", "sha256": "08b5dd3118b1f5e2ab9e0ee822474396c95cf5f662fd752003472eebc27a339c" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.7.tar.gz", "has_sig": false, "md5_digest": "e722daf545db6f2c1c7b8295086414ea", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3743, "upload_time": "2019-08-09T12:46:06", "upload_time_iso_8601": "2019-08-09T12:46:06.635521Z", "url": "https://files.pythonhosted.org/packages/bd/48/b4b5d197be5e2ab0d33119130e56ae1aa3faa870313e497e2a9ec96242d9/greendeck-rabbitmq-1.0.7.tar.gz", "yanked": false, "yanked_reason": null } ], "1.0.9": [ { "comment_text": "", "digests": { "md5": "3afa9717722c3c0172d63b7c88b361e7", "sha256": "9c435cea0a40bfe58a3ab1e4736176704204918c0cea41a14942563991902065" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.9.tar.gz", "has_sig": false, "md5_digest": "3afa9717722c3c0172d63b7c88b361e7", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3758, "upload_time": "2019-08-10T11:32:36", "upload_time_iso_8601": "2019-08-10T11:32:36.307714Z", "url": "https://files.pythonhosted.org/packages/0c/a8/f3f5d0c5d54934caf52806ad30b0bd0730ff00cc117a57fb001adc0143b6/greendeck-rabbitmq-1.0.9.tar.gz", "yanked": false, "yanked_reason": null } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "094ee04f18892caebd980e996d144aa6", "sha256": "3de288c551353164b71215c8ec5ef591be5340cd8d369f355a4915bcce77516b" }, "downloads": -1, "filename": "greendeck-rabbitmq-1.0.16.tar.gz", "has_sig": false, "md5_digest": "094ee04f18892caebd980e996d144aa6", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4860, "upload_time": "2019-10-23T13:11:35", "upload_time_iso_8601": "2019-10-23T13:11:35.124652Z", "url": "https://files.pythonhosted.org/packages/4a/4c/640bacdc600de43fa82bd79a0ccc677a4e2dbe86f2df6cbf0599464d7dd1/greendeck-rabbitmq-1.0.16.tar.gz", "yanked": false, "yanked_reason": null } ], "vulnerabilities": [] }