amazon-kinesis-client-pythonAmazon KCL 的 Python 庫(kù)

amazon-kinesis-client-python 提供了一個(gè)到 Amazon Kinesis Client Library（KCL）接口，它是 Amazon KCL for Java 的一部分。開(kāi)發(fā)者可以用 Amazon KCL 建立可處理大規(guī)模流數(shù)據(jù)的分布式應(yīng)用程序。Amazon KCL 照顧了很多與分布式計(jì)算相關(guān)的復(fù)雜任務(wù)。這個(gè)接口管理著 MultiLangDaemon 的交互，所以開(kāi)發(fā)者可以專注于實(shí)現(xiàn)他們可執(zhí)行的記錄處理器。

示例代碼：

    #!env python
    from amazon_kclpy import kcl    import json, base64
    class RecordProcessor(kcl.RecordProcessorBase):
            def initialize(self, shard_id):
            pass

        def process_records(self, records, checkpointer):
            pass

        def shutdown(self, checkpointer, reason):
            pass

    if __name__ == "__main__":
        kclprocess = kcl.KCLProcess(RecordProcessor())
        kclprocess.run()