を使用して、スタッガーデータを含む Kinesis ストリームを生成します。AWSSDK

次のコード例は、スタッガーデータを含む Kinesis ストリームを生成する方法を示しています。

詳細については、「」を参照してください。例:スタッガーウィンドウ。

Python

SDK for Python (Boto3)

注記

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

import datetime
import json
import random
import time
import boto3

STREAM_NAME = "ExampleInputStream"


def get_data():
    event_time = datetime.datetime.utcnow() - datetime.timedelta(seconds=10)
    return {
        'EVENT_TIME': event_time.isoformat(),
        'TICKER': random.choice(['AAPL', 'AMZN', 'MSFT', 'INTC', 'TBV'])}


def generate(stream_name, kinesis_client):
    while True:
        data = get_data()
        # Send six records, ten seconds apart, with the same event time and ticker
        for _ in range(6):
            print(data)
            kinesis_client.put_record(
                StreamName=stream_name,
                Data=json.dumps(data),
                PartitionKey="partitionkey")
            time.sleep(10)


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