# Базовое API для работы с RabbitMQ
``BaseConsumer`` - базовый потребитель очереди сообщений
``Publisher`` - базовый издатель очереди сообщений
``ReplyToConsumer`` - reply to потребитель
## Python modules
### mq_misc.publish info
```
python -m mq_misc.publish -h
usage: __main__.py [-h] [-m MESSAGE] [-f MESSAGE_FILE] -url AMQP_URL
[-q QUEUE] [-e EXCHANGE] [--exchange_type EXCHANGE_TYPE]
[-k ROUTING_KEY] [-to REPLY_TO] [-id CORRELATION_ID] [-w]
If an arg is specified in more than one place, then commandline values
override environment variables which override defaults.
optional arguments:
-h, --help show this help message and exit
-m MESSAGE, --message MESSAGE
The message being sent [env var: RMQ_MESSAGE]
(default: None)
-f MESSAGE_FILE, --message-file MESSAGE_FILE
File with the message [env var: RMQ_MESSAGE_FILE]
(default: None)
-to REPLY_TO, --reply_to REPLY_TO
Commonly used to name a callback queue [env var:
RMQ_REPLY_TO] (default: None)
-id CORRELATION_ID, --correlation_id CORRELATION_ID
Useful to correlate RPC responses with requests. [env
var: RMQ_CORRELATION_ID] (default: None)
-w, --waiting_response
Waiting reply_to response. [env var:
RMQ_WAITING_RESPONSE] (default: False)
Rabbit MQ options:
-url AMQP_URL, --amqp-url AMQP_URL
URL to use to connect to the rabbitmq [env var:
RMQ_AMQP_URL] (default: None)
-q QUEUE, --queue QUEUE
Queue to use to connect to the rabbitmq [env var:
RMQ_QUEUE] (default: None)
-e EXCHANGE, --exchange EXCHANGE
Exchange to use to connect to the rabbitmq [env var:
RMQ_EXCHANGE] (default: None)
--exchange_type EXCHANGE_TYPE
Exchange type to use to connect to the rabbitmq [env
var: RMQ_EXCHANGE_TYPE] (default: direct)
-k ROUTING_KEY, --routing_key ROUTING_KEY
Routing key for publish message [env var:
RMQ_ROUTING_KEY] (default: None)
```
python -m mq_misc.publish --amqp-url "amqp://guest:guest@localhost:5672/" --exchange "exchange_1" --exchange_type "
topic" --routing_key "log.error" --message-file "message.json"
Raw data
{
"_id": null,
"home_page": "",
"name": "mq-misc",
"maintainer": "",
"docs_url": null,
"requires_python": ">=3.8",
"maintainer_email": "",
"keywords": "python,asyncio,utils,mq,aio_pika,rabbit mq,rabbit",
"author": "Anton Gorinenko",
"author_email": "anton.gorinenko@gmail.com",
"download_url": "https://files.pythonhosted.org/packages/f1/fe/4c9d961647b18c9998d8339f3434ec47dd88b8eb58a29a01f56d6b8ffee7/mq-misc-0.0.6.tar.gz",
"platform": null,
"description": "# \u0411\u0430\u0437\u043e\u0432\u043e\u0435 API \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 RabbitMQ\n\n``BaseConsumer`` - \u0431\u0430\u0437\u043e\u0432\u044b\u0439 \u043f\u043e\u0442\u0440\u0435\u0431\u0438\u0442\u0435\u043b\u044c \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \n``Publisher`` - \u0431\u0430\u0437\u043e\u0432\u044b\u0439 \u0438\u0437\u0434\u0430\u0442\u0435\u043b\u044c \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \n``ReplyToConsumer`` - reply to \u043f\u043e\u0442\u0440\u0435\u0431\u0438\u0442\u0435\u043b\u044c\n\n## Python modules\n\n### mq_misc.publish info\n\n```\npython -m mq_misc.publish -h\n\nusage: __main__.py [-h] [-m MESSAGE] [-f MESSAGE_FILE] -url AMQP_URL\n [-q QUEUE] [-e EXCHANGE] [--exchange_type EXCHANGE_TYPE]\n [-k ROUTING_KEY] [-to REPLY_TO] [-id CORRELATION_ID] [-w]\n\nIf an arg is specified in more than one place, then commandline values\noverride environment variables which override defaults.\n\noptional arguments:\n -h, --help show this help message and exit\n -m MESSAGE, --message MESSAGE\n The message being sent [env var: RMQ_MESSAGE]\n (default: None)\n -f MESSAGE_FILE, --message-file MESSAGE_FILE\n File with the message [env var: RMQ_MESSAGE_FILE]\n (default: None)\n -to REPLY_TO, --reply_to REPLY_TO\n Commonly used to name a callback queue [env var:\n RMQ_REPLY_TO] (default: None)\n -id CORRELATION_ID, --correlation_id CORRELATION_ID\n Useful to correlate RPC responses with requests. [env\n var: RMQ_CORRELATION_ID] (default: None)\n -w, --waiting_response\n Waiting reply_to response. [env var:\n RMQ_WAITING_RESPONSE] (default: False)\n\nRabbit MQ options:\n -url AMQP_URL, --amqp-url AMQP_URL\n URL to use to connect to the rabbitmq [env var:\n RMQ_AMQP_URL] (default: None)\n -q QUEUE, --queue QUEUE\n Queue to use to connect to the rabbitmq [env var:\n RMQ_QUEUE] (default: None)\n -e EXCHANGE, --exchange EXCHANGE\n Exchange to use to connect to the rabbitmq [env var:\n RMQ_EXCHANGE] (default: None)\n --exchange_type EXCHANGE_TYPE\n Exchange type to use to connect to the rabbitmq [env\n var: RMQ_EXCHANGE_TYPE] (default: direct)\n -k ROUTING_KEY, --routing_key ROUTING_KEY\n Routing key for publish message [env var:\n RMQ_ROUTING_KEY] (default: None)\n\n\n```\n\npython -m mq_misc.publish --amqp-url \"amqp://guest:guest@localhost:5672/\" --exchange \"exchange_1\" --exchange_type \"\ntopic\" --routing_key \"log.error\" --message-file \"message.json\"\n",
"bugtrack_url": null,
"license": "",
"summary": "Utility package for working with rabbitmq",
"version": "0.0.6",
"project_urls": null,
"split_keywords": [
"python",
"asyncio",
"utils",
"mq",
"aio_pika",
"rabbit mq",
"rabbit"
],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "5090d16987c192a30321f64d54cf915a92b9b7134c5d810d725f0070cef0a20f",
"md5": "711c951e126950096feca35ea63ab8e4",
"sha256": "e507167c424ff2dab3eca1e222474f4f035b8533e60b9398e82b1d2f8f397ebe"
},
"downloads": -1,
"filename": "mq_misc-0.0.6-py3-none-any.whl",
"has_sig": false,
"md5_digest": "711c951e126950096feca35ea63ab8e4",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": ">=3.8",
"size": 11063,
"upload_time": "2023-09-14T13:02:41",
"upload_time_iso_8601": "2023-09-14T13:02:41.036448Z",
"url": "https://files.pythonhosted.org/packages/50/90/d16987c192a30321f64d54cf915a92b9b7134c5d810d725f0070cef0a20f/mq_misc-0.0.6-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "f1fe4c9d961647b18c9998d8339f3434ec47dd88b8eb58a29a01f56d6b8ffee7",
"md5": "1cc8285cd0a0b3b9fdec20c18b8e0fd8",
"sha256": "f8808992e17d361fdaec34c8585528ada2d3aae432510146175287d39e665de4"
},
"downloads": -1,
"filename": "mq-misc-0.0.6.tar.gz",
"has_sig": false,
"md5_digest": "1cc8285cd0a0b3b9fdec20c18b8e0fd8",
"packagetype": "sdist",
"python_version": "source",
"requires_python": ">=3.8",
"size": 11557,
"upload_time": "2023-09-14T13:02:42",
"upload_time_iso_8601": "2023-09-14T13:02:42.196055Z",
"url": "https://files.pythonhosted.org/packages/f1/fe/4c9d961647b18c9998d8339f3434ec47dd88b8eb58a29a01f56d6b8ffee7/mq-misc-0.0.6.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2023-09-14 13:02:42",
"github": false,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"lcname": "mq-misc"
}
JSON