SDK for Python (Boto3) を使用した Amazon MSKの例 - AWS SDK CLI コードの例
サーバーレスサンプル

AWS Doc SDK Examples GitHub リポジトリには他にも AWS SDK例があります。

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

SDK for Python (Boto3) を使用した Amazon MSKの例

次のコード例は、Amazon AWS SDK for Python (Boto3) で を使用してアクションを実行し、一般的なシナリオを実装する方法を示していますMSK。

各例には、完全なソースコードへのリンクが含まれています。このリンクには、コンテキスト内でコードをセットアップして実行する方法の手順が記載されています。

サーバーレスサンプル

次のコード例は、Amazon MSKクラスターからレコードを受信することによってトリガーされるイベントを受信する Lambda 関数を実装する方法を示しています。関数はMSKペイロードを取得し、レコードの内容をログに記録します。

SDK for Python (Boto3)
注記

詳細については、「」を参照してください GitHub。サーバーレスサンプルリポジトリで完全な例を検索し、設定および実行の方法を確認してください。

Python を使用した Lambda での Amazon MSKイベントの消費。


import base64

def lambda_handler(event, context):
    # Iterate through keys
    for key in event['records']:
        print('Key:', key)
        # Iterate through records
        for record in event['records'][key]:
            print('Record:', record)
            # Decode base64
            msg = base64.b64decode(record['value']).decode('utf-8')
            print('Message:', msg)