まだまだありますAWSSDK のサンプルは以下にあります。AWSドキュメント SDK サンプル GitHubレポ。
翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
を使用して、スタッガーデータを含む Kinesis ストリームを生成します。AWSSDK
次のコード例は、スタッガーデータを含む Kinesis ストリームを生成する方法を示しています。
詳細については、「」を参照してください。例:スタッガーウィンドウ。
- Python
-
- SDK for Python (Boto3)
-
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'))