{ "info": { "author": "Stream Developer", "author_email": "hzhuangzhenxi@corp.netease.com", "bugtrack_url": null, "classifiers": [ "Development Status :: 5 - Production/Stable", "Intended Audience :: Developers", "License :: OSI Approved :: MIT License", "Operating System :: OS Independent", "Programming Language :: Python", "Programming Language :: Python :: 2", "Programming Language :: Python :: 2.6", "Programming Language :: Python :: 2.7" ], "description": "Stream Python SDK\n==============\n\nStream Python SDK\u5b9e\u73b0\u4e86Stream \u65e5\u5fd7\u64cd\u4f5c\u63a5\u53e3\uff0c\u57fa\u4e8e\u6b64SDK\u80fd\u65b9\u4fbf\u5feb\u901f\u5730\u5b9e\u73b0Python\u5e94\u7528\u7a0b\u5e8f\u6765\u5bf9\u8ba2\u9605\u65e5\u5fd7\u8fdb\u884c\u76f8\u5173\u64cd\u4f5c\u3002\n\n\u652f\u6301\u7684\u529f\u80fd\n----------\n\n\u65e5\u5fd7\u64cd\u4f5c\u63a5\u53e3\n^^^^^^^^^^^^\n\n* Get Subscription Position \u2014\u2014 \u83b7\u53d6\u8ba2\u9605\u65e5\u5fd7\u4f4d\u7f6e\n* Get Logs \u2014\u2014 \u83b7\u53d6\u6307\u5b9a\u8ba2\u9605\u65e5\u5fd7\n\n\u63a5\u53e3\u5b9e\u73b0\n--------\n\n\u5728\u8c03\u7528\u5bf9\u8c61\u64cd\u4f5c\u63a5\u53e3\u524d\u9700\u8981\u751f\u6210\u4e00\u4e2astream_client.StreamClient\u7c7b\u7684\u5b9e\u4f8b\u3002\u4e14\u5728\u8c03\u7528\u64cd\u4f5c\u63a5\u53e3\u65f6\uff0c\u90fd\u6709\u53ef\u80fd\u629b\u51fa\u5f02\u5e38\uff0c\u53ef\u4ee5\u4f7f\u7528'stream.exceptions.ServiceException'\u6355\u83b7stream\u670d\u52a1\u5668\u5f02\u5e38\u9519\u8bef\uff0c\u4f7f\u7528'stream.exceptions.ClientException'\u6355\u83b7stream\u5ba2\u6237\u7aef\u5f02\u5e38\u9519\u8bef\u3002\n\nstream_client.StreamClient\u5bf9\u8c61\u5b9e\u4f8b\u5316\n\n\u4f7f\u7528\u4e3e\u4f8b\n\n::\n\n client = stream_client.StreamClient(\n access_key_id=\"string\",\n access_key_secret=\"string\"\n )\n\n\u53c2\u6570\u8bf4\u660e\n\n* access_key_id(string) -- \u8bbf\u95ee\u51ed\u8bc1ID\u3002\n* access_key_secret(string) -- \u8bbf\u95ee\u51ed\u8bc1\u5bc6\u94a5\u3002\n\nstream_client.StreamClient\u53ef\u80fd\u5f15\u53d1\u7684\u6240\u6709\u5f02\u5e38\u7c7b\u578b\n\n\u5728\u7a0b\u5e8f\u8fd0\u884c\u8fc7\u7a0b\u4e2d\uff0c\u5982\u679c\u9047\u5230\u9519\u8bef\uff0cPython SDK\u4f1a\u629b\u51fa\u76f8\u5e94\u7684\u5f02\u5e38\u3002\u6240\u6709\u5f02\u5e38\u5747\u5c5e\u4e8eStreamException\u7c7b\uff0c\u5176\u4e0b\u5206\u4e3a\u4e24\u4e2a\u5b50\u7c7b\uff1aClientException\u3001ServiceException\u3002\u5728\u8c03\u7528Python SDK\u63a5\u53e3\u7684\u65f6\u5019\uff0c\u6355\u6349\u8fd9\u4e9b\u5f02\u5e38\u5e76\u6253\u5370\u5fc5\u8981\u7684\u4fe1\u606f\u6709\u5229\u4e8e\u5b9a\u4f4d\u95ee\u9898\u3002\n\nClientException\n:::::::::::::::\n\nClientException\u5305\u542bSDK\u5ba2\u6237\u7aef\u7684\u5f02\u5e38\u3002\u6bd4\u5982\uff0c\u4e0a\u4f20\u5bf9\u8c61\u65f6\u5bf9\u8c61\u540d\u4e3a\u7a7a\uff0c\u5c31\u4f1a\u629b\u51fa\u8be5\u5f02\u5e38\u3002\nClientException\u7c7b\u4e0b\u6709\u5982\u4e0b\u5b50\u7c7b\uff0c\u7528\u4e8e\u7ec6\u5206\u5ba2\u6237\u7aef\u5f02\u5e38\uff1a\n\n.. list-table::\n :widths: 5 10\n :header-rows: 1\n\n * - \u7c7b\u540d\n - \u629b\u51fa\u5f02\u5e38\u7684\u539f\u56e0\n * - InvalidParameter\n - \u4f20\u5165\u7684\u53c2\u6570\u975e\u6cd5\n * - SerializationError\n - \u4e0a\u4f20\u5bf9\u8c61\u5e8f\u5217\u5316\u5931\u8d25\n * - ConnectionError\n - \u8fde\u63a5\u670d\u52a1\u7aef\u5f02\u5e38\n * - ConnectionTimeout\n - \u8fde\u63a5\u670d\u52a1\u7aef\u8d85\u65f6\n\nServiceException\n::::::::::::::::\n\nServiceException\u5305\u542bStream\u670d\u52a1\u5668\u8fd4\u56de\u7684\u5f02\u5e38\u3002\u5f53Stream\u670d\u52a1\u5668\u8fd4\u56de4xx\u62165xx\u7684HTTP\u9519\u8bef\u7801\u65f6\uff0cPython SDK\u4f1a\u5c06Stream Server\u7684\u54cd\u5e94\u8f6c\u6362\u4e3aServiceException\u3002\nServiceException\u7c7b\u4e0b\u6709\u5982\u4e0b\u5b50\u7c7b\uff0c\u7528\u4e8e\u7ec6\u5206Stream\u670d\u52a1\u5668\u8fd4\u56de\u7684\u5f02\u5e38\uff1a\n\n.. list-table::\n :widths: 5 10\n :header-rows: 1\n\n * - \u7c7b\u540d\n - \u629b\u51fa\u5f02\u5e38\u7684\u539f\u56e0\n * - BadRequestError\n - \u670d\u52a1\u7aef\u8fd4\u56deHTTP 400\u54cd\u5e94\n * - ForbiddenError\n - \u670d\u52a1\u7aef\u8fd4\u56deHTTP 403\u54cd\u5e94\n * - NotFoundError\n - \u670d\u52a1\u7aef\u8fd4\u56deHTTP 404\u54cd\u5e94\n * - MethodNotAllowedError\n - \u670d\u52a1\u7aef\u8fd4\u56deHTTP 405\u54cd\u5e94\n * - ConflictError\n - \u670d\u52a1\u7aef\u8fd4\u56deHTTP 409\u54cd\u5e94\n * - LengthRequiredError\n - \u670d\u52a1\u7aef\u8fd4\u56deHTTP 411\u54cd\u5e94\n * - RequestedRangeNotSatisfiableError\n - \u670d\u52a1\u7aef\u8fd4\u56deHTTP 416\u54cd\u5e94\n * - InternalServerErrorError\n - \u670d\u52a1\u7aef\u8fd4\u56deHTTP 500\u54cd\u5e94\n * - NotImplementedError\n - \u670d\u52a1\u7aef\u8fd4\u56deHTTP 501\u54cd\u5e94\n * - ServiceUnavailableError\n - \u670d\u52a1\u7aef\u8fd4\u56deHTTP 503\u54cd\u5e94\n\nstream_client.StreamClient\u7684\u4f7f\u7528\u548c\u5f02\u5e38\u5904\u7406\u7684\u793a\u4f8b\u4ee3\u7801\n\n::\n\n try:\n resp = stream_client.StreamClient.XXX(\n subscription_name=subscription_name,\n position_type=position_type\n )\n except stream.exceptions.ServiceException as e:\n print (\n 'ServiceException: %s\\n'\n 'message: %s\\n'\n ) % (\n e,\n e.message # \u9519\u8bef\u63cf\u8ff0\u4fe1\u606f\n )\n except stream.exceptions.ClientException as e:\n print (\n 'ClientException: %s\\n'\n 'message: %s\\n'\n ) % (\n e,\n e.message # \u5ba2\u6237\u7aef\u9519\u8bef\u4fe1\u606f\n )\n\n\u65e5\u5fd7\u64cd\u4f5c\u63a5\u53e3\n^^^^^^^^^^^^\n\nGet Subscription Position\n:::::::::::::\n\n\u4f7f\u7528\u4e3e\u4f8b\n\n::\n\n resp = client.get_subscription_position(\n subscription_name=topic_name,\n position_type=position_type\n )\n\n\u53c2\u6570\u8bf4\u660e\n\n* subscription_name(string) -- \u8ba2\u9605\u4e3b\u9898\u540d\u79f0\u3002\n* position_type(string) -- \u83b7\u53d6\u4f4d\u7f6e\u7c7b\u578b\u3002\n\n\u8fd4\u56de\u503c\u4e3e\u4f8b\n\n::\n\n {\n \"position\": \"dGVzdDIw33YxMjE1MTkwMy5kZWZhdWx0LXdtM3pxOjEw\"\n }\n\n\u8fd4\u56de\u503c\u8bf4\u660e\n\u8fd4\u56de\u503c\u4e3a\u5b57\u5178\u7c7b\u578b\n\n* position(string) -- \u65e5\u5fd7\u4f4d\u7f6e\u3002\n\n\nGet Logs\n:::::::::::::::::::::::\n\n\u4f7f\u7528\u4e3e\u4f8b\n\n::\n\n resp = client.get_logs(\n subscription_name=topic_name,\n logs_position=logs_position,\n limit=limit\n )\n\n\u53c2\u6570\u8bf4\u660e\n\n* subscription_name(string) -- \u8ba2\u9605\u4e3b\u9898\u540d\u79f0\u3002\n* logs_position(string) -- \u65e5\u5fd7\u4f4d\u7f6e\u3002\n* limit(int) -- \u83b7\u53d6\u65e5\u5fd7\u6761\u6570\u9650\u5236\u3002\n\n\u8fd4\u56de\u503c\u4e3e\u4f8b\n\n::\n\n {\n \"subscription_logs\": [\n {\n \"timestamp\": 1482467113427,\n \"message\": \"ksjfkajfkasfs\"\n }\n ],\n \"count\": 1,\n \"next_position\": \"dGVzdDIwMTYxMjE1MTkwMy5kZWZhdWx0LXdtM3pxOjEx\",\n \"reached_ending\": false\n }", "description_content_type": null, "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/NetEase-Cloudsearch/stream-python-sdk", "keywords": "", "license": "MIT License", "maintainer": "", "maintainer_email": "", "name": "stream-python-sdk", "package_url": "https://pypi.org/project/stream-python-sdk/", "platform": "", "project_url": "https://pypi.org/project/stream-python-sdk/", "project_urls": { "Homepage": "https://github.com/NetEase-Cloudsearch/stream-python-sdk" }, "release_url": "https://pypi.org/project/stream-python-sdk/0.2/", "requires_dist": null, "requires_python": "", "summary": "Stream SDK", "version": "0.2" }, "last_serial": 2584765, "releases": { "0.1": [], "0.2": [ { "comment_text": "", "digests": { "md5": "4c2c6202f708c0f3e4673f947de23677", "sha256": "e2057504eba3e0816fd4d11f53e3519b93bc4bb2a70f2a87f3ca966e7004763a" }, "downloads": -1, "filename": "stream-python-sdk-0.2.tar.gz", "has_sig": false, "md5_digest": "4c2c6202f708c0f3e4673f947de23677", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 11256, "upload_time": "2017-01-19T12:41:42", "url": "https://files.pythonhosted.org/packages/85/2b/d8c7cae74055cae053d0f38520c304a36b0e38d0c88464c639aa0315bf39/stream-python-sdk-0.2.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "4c2c6202f708c0f3e4673f947de23677", "sha256": "e2057504eba3e0816fd4d11f53e3519b93bc4bb2a70f2a87f3ca966e7004763a" }, "downloads": -1, "filename": "stream-python-sdk-0.2.tar.gz", "has_sig": false, "md5_digest": "4c2c6202f708c0f3e4673f947de23677", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 11256, "upload_time": "2017-01-19T12:41:42", "url": "https://files.pythonhosted.org/packages/85/2b/d8c7cae74055cae053d0f38520c304a36b0e38d0c88464c639aa0315bf39/stream-python-sdk-0.2.tar.gz" } ] }