AWSSDK を使用してウェブログデータを含む Kinesis ストリームを生成する - AWSSDK コードサンプル

AWSDocAWS SDKGitHub サンプルリポジトリには、さらに多くの SDK サンプルがあります

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

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'))