{
    "info": {
        "author": "HaiFeng",
        "author_email": "haifengat@vip.qq.com",
        "bugtrack_url": null,
        "classifiers": [
            "License :: OSI Approved :: MIT License",
            "Operating System :: OS Independent",
            "Programming Language :: Python :: 3",
            "Programming Language :: Python :: 3.6",
            "Programming Language :: Python :: 3.7"
        ],
        "description": "# ali rocketMQ for python\n\n## \u8bf4\u660e\n\n\u5b98\u65b9so\u8def\u5f84\u8981\u52a0\u5230LD_LIBRARY_PATH\u4e2d\n\n## \u8c03\u7528\u793a\u4f8b\n\n```python\n#!/usr/bin/env python\n# -*- coding: utf-8 -*-\n# @Author  : HaiFeng\n# @Email   : 24918700@qq.com\n# @Time    : 2019/1/16\n# @desc    : demo ali rocketmq\n\nimport sys\nimport time\nfrom py_rmq.rmq_consumer import Consumer\nfrom py_rmq.rmq_producer import Producer\nfrom py_rmq.rmq_consumer import OrderConsumer\nfrom py_rmq.rmq_producer import OrderProducer\n\ndef OnConsumer(topic: str, tag: str, key: str, id: str, deliver_time: int, body: str, reconsume_times: int, store_time: int, offset: int):\n    print(body)\n\n\nif __name__ == '__main__':\n\n    t:str = ''\n    id:str = ''\n    access:str = ''\n    secret:str = ''\n    topic:str = ''\n\n    if len(sys.argv) > 1:\n        t = sys.argv[1].lower()\n        if len(sys.argv) > 2:\n            id = sys.argv[2]\n            if len(sys.argv) > 3:\n                access = sys.argv[3]\n                if len(sys.argv) > 4:\n                    secret = sys.argv[4]\n                    if len(sys.argv) > 5:\n                        topic = sys.argv[5]\n    if t == '':\n        t = input('select consumer or producer:').lower()\n    if id == '':\n        id = input('input cid or pid:')\n    if access == '':\n        access = input('input acces key:')\n    if secret == '':\n        secret = input('input secret key:')\n    if topic == '':\n        topic = input('input topic:')\n    if t == 'consumer':\n        print('test consumer...')\n        c = Consumer(id, access, secret)\n        c.OnConsumer = OnConsumer\n        c.subscribe(topic, '*')\n        input('press enter to continue test order consumer')\n        c.close()\n\n        print('test order consumer...')\n        c = OrderConsumer(id, access, secret)\n        c.OnConsumer = OnConsumer\n        c.subscribe(topic, '*')\n        input('press enter exit')\n        c.close()\n    else:\n        tag = 'tag test'\n\n        key = time.strftime('%Y%m%d%H%M%S', time.localtime())\n\n        print('test producer...')\n        p = Producer(id, access, secret)\n        msg = input('input content: ')\n        rst = p.send_msg(topic, tag, key, msg)\n        print(f'result: {rst}')\n        print('test delive msg, delive 30s')\n        rst = p.send_msg(topic, tag, key, msg + 'delive', int(time.time() * 1000) + 30000)\n        print(f'delive msg result: {rst}')\n        p.close()\n\n        input('press enter continue test order producer')\n        p = OrderProducer(id, access, secret)\n        sharding_key = input('input sharding_key: ')\n        rst = p.send_msg(topic, tag, key, msg, sharding_key)\n        print(f'order msg result: {rst}')\n        p.close()\n```",
        "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/haifengat/py_rmq",
        "keywords": "",
        "license": "MIT License",
        "maintainer": "",
        "maintainer_email": "",
        "name": "py-rmq",
        "package_url": "https://pypi.org/project/py-rmq/",
        "platform": "x64",
        "project_url": "https://pypi.org/project/py-rmq/",
        "project_urls": {
            "Homepage": "https://github.com/haifengat/py_rmq"
        },
        "release_url": "https://pypi.org/project/py-rmq/0.0.5/",
        "requires_dist": null,
        "requires_python": ">=3.6.0",
        "summary": "Python ali rocketMQ api",
        "version": "0.0.5"
    },
    "last_serial": 4705876,
    "releases": {
        "0.0.3": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "4cc36f2a18f4a1520fcd3bb7a82eef98",
                    "sha256": "ceae6a9455cb9c422d106684bf18dcf446894559aed2c41707831904a0226552"
                },
                "downloads": -1,
                "filename": "py_rmq-0.0.3.tar.gz",
                "has_sig": false,
                "md5_digest": "4cc36f2a18f4a1520fcd3bb7a82eef98",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": ">=3.6.0",
                "size": 26871,
                "upload_time": "2019-01-17T01:55:59",
                "url": "https://files.pythonhosted.org/packages/4c/1a/ab52261d208000ce10251682699035c0d0bb55cd4d914503aab6cb053863/py_rmq-0.0.3.tar.gz"
            }
        ],
        "0.0.5": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "3b113804f4aecf788efea46e27b38bb8",
                    "sha256": "d3a54eebb3b3c99eaf6ba3c379c8606638289a5d97fa9e2b33ef6d3f5c5f4771"
                },
                "downloads": -1,
                "filename": "py_rmq-0.0.5.tar.gz",
                "has_sig": false,
                "md5_digest": "3b113804f4aecf788efea46e27b38bb8",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": ">=3.6.0",
                "size": 26881,
                "upload_time": "2019-01-17T02:01:36",
                "url": "https://files.pythonhosted.org/packages/83/7f/5e10b63451a36de67dd9b3e12cb3bdb25a1ece87afa9bfd43b68ad0367cf/py_rmq-0.0.5.tar.gz"
            }
        ]
    },
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "md5": "3b113804f4aecf788efea46e27b38bb8",
                "sha256": "d3a54eebb3b3c99eaf6ba3c379c8606638289a5d97fa9e2b33ef6d3f5c5f4771"
            },
            "downloads": -1,
            "filename": "py_rmq-0.0.5.tar.gz",
            "has_sig": false,
            "md5_digest": "3b113804f4aecf788efea46e27b38bb8",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": ">=3.6.0",
            "size": 26881,
            "upload_time": "2019-01-17T02:01:36",
            "url": "https://files.pythonhosted.org/packages/83/7f/5e10b63451a36de67dd9b3e12cb3bdb25a1ece87afa9bfd43b68ad0367cf/py_rmq-0.0.5.tar.gz"
        }
    ]
}