AWSSDK を使用してウェブログデータを含む Kinesis ストリームを生成する

次のコード例は、Web ログデータを使用して、Kinesis ストリームを生成する方法を示しています。

詳細については、「例:Web ログの解析」を参照してください。

Python

SDK for Python (Boto3)

注記

他にもありますGitHub。用例一覧を検索し、AWS コード例リポジトリでの設定と実行の方法を確認してください。

import json
import boto3

STREAM_NAME = "ExampleInputStream"


def get_data():
    return {'log': '192.168.254.30 - John [24/May/2004:22:01:02 -0700] '
                   '"GET /icons/apache_pb.gif HTTP/1.1" 304 0'}


def generate(stream_name, kinesis_client):
    while True:
        data = get_data()
        print(data)
        kinesis_client.put_record(
            StreamName=stream_name,
            Data=json.dumps(data),
            PartitionKey="partitionkey")


if __name__ == '__main__':
    generate(STREAM_NAME, boto3.client('kinesis'))