amazon-kinesis-client-python:适用于Python的Amazon Kinesis客户端库

时间:2024-06-11 01:26:52
【文件属性】:

文件名称:amazon-kinesis-client-python:适用于Python的Amazon Kinesis客户端库

文件大小:61KB

文件格式:ZIP

更新时间:2024-06-11 01:26:52

Python

适用于Python的Amazon Kinesis客户端库 该软件包提供了到Amazon Kinesis Client Library(KCL)MultiLangDaemon的接口,该接口是。 开发人员可以使用构建分布式应用程序,以可靠地大规模处理流数据。 负责与分布式计算相关的许多复杂任务,例如,跨多个实例的负载平衡,对实例故障做出响应,对处理的记录进行检查点检查以及对流量的变化做出React。 此接口管理与MultiLangDaemon的交互,以便开发人员可以专注于实现其记录处理器可执行文件。 记录处理器可执行文件通常如下所示: #!env python from amazon_kclpy import kcl import json , base64 class RecordProcessor ( kcl . RecordProcessorBase )


【文件预览】:
amazon-kinesis-client-python-master
----.gitignore(125B)
----setup.cfg(61B)
----README.md(13KB)
----.github()
--------PULL_REQUEST_TEMPLATE.md(197B)
----test()
--------test_amazon_kclpy_input_output_integration.py(4KB)
--------conftest.py(178B)
--------utils.py(394B)
--------__init__.py(112B)
--------test_amazon_kclpy.py(4KB)
--------v3()
----docs()
--------make.bat(7KB)
--------guide()
--------conf.py(10KB)
--------index.rst(1KB)
--------Makefile(8KB)
----amazon_kclpy()
--------checkpoint_error.py(781B)
--------messages.py(13KB)
--------kcl.py(12KB)
--------__init__.py(827B)
--------v2()
--------jars()
--------v3()
--------dispatch.py(2KB)
----CONTRIBUTING.md(4KB)
----CODE_OF_CONDUCT.md(311B)
----scripts()
--------build_deps.py(3KB)
----requirements.txt(18B)
----LICENSE.txt(10KB)
----MANIFEST.in(57B)
----setup.py(11KB)
----samples()
--------sample.properties(4KB)
--------amazon_kclpy_helper.py(7KB)
--------sample_kinesis_wordputter.py(6KB)
--------sample_kclpy_app.py(7KB)
--------__init__.py(3KB)
----NOTICE.txt(114B)

网友评论