View a markdown version of this page

建立 Amazon S3 交付 - Amazon Kinesis Data Streams
使用 AWS 管理主控台使用 AWS CLI

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

建立 Amazon S3 交付

建立將記錄從 Amazon Kinesis Data Streams 串流傳送至一般用途 Amazon S3 儲存貯體的交付。您可以使用 AWS 管理主控台 或 建立交付 AWS CLI。記錄會以其來源格式交付，批次處理為大小最佳的物件，並具有可設定的壓縮和您定義的 S3 金鑰結構。

注意

建立交付之前，請先完成 中的先決條件S3 一般用途交付入門，包括 中所述的 IAM 服務執行角色資料交付的 IAM 許可。

使用 AWS 管理主控台

  1. 在 開啟 Kinesis 主控台https://console.aws.amazon.com/kinesis。

  2. 在導覽窗格中，選擇 S3 一般用途交付，然後選擇建立交付。

  3. 步驟 1：來源組態。在交付詳細資訊下，輸入交付名稱。針對來源，選擇要交付的隨需串流。只會顯示隨需串流。選擇下一步。

  4. 步驟 2：目的地組態。選擇記錄格式 (JSON、STRING 或 BYTE_ARRAY)，然後指定目的地：

    • S3 儲存貯體 ARN – 目的地一般用途 Amazon S3 儲存貯體的 ARN。

    • 預期的儲存貯體擁有者 – 預期儲存貯體擁有者的 12 位數 AWS 帳戶 ID。

    • 壓縮類型 – 選擇 GZIP、ZSTD 或無。

    • 儲存類別 – 選擇性地選擇 Amazon S3 儲存類別。

    • 輸出金鑰範本 – 選擇性地定義 Amazon S3 物件金鑰結構。如需詳細資訊，請參閱Amazon S3 交付的 S3 輸出金鑰範本。

    • 資料新鮮度 – 傳送記錄前的緩衝時間上限，以秒為單位 （下限為 300，上限為 900)。

    選擇下一步。

  5. 步驟 3：其他組態。設定加密、服務存取 (IAM 角色）、選用的無效字母佇列、日誌交付和標籤。選擇下一步。

  6. 步驟 4：檢閱和建立。檢閱您的組態，然後選擇建立交付。佈建完成後，交付會從 CREATING 轉換為 ACTIVE。

使用 AWS CLI

使用 create-channel命令來建立 Amazon S3 交付，將記錄傳送到具有 JSON 格式和 GZIP 壓縮的一般用途 Amazon S3 儲存貯體：

aws kinesis create-channel \
    --channel-name "my-s3-delivery" \
    --service-execution-role-arn "arn:aws:iam::123456789012:role/my-channel-role" \
    --stream-configuration-list '[
        {
            "StreamARN": "arn:aws:kinesis:us-east-1:123456789012:stream/my-stream",
            "RecordConfiguration": {
                "RecordFormatType": "JSON"
            }
        }
    ]' \
    --s3-destination-configuration '{
        "DataFreshnessInSeconds": 300,
        "StorageConfiguration": {
            "BucketARN": "arn:aws:s3:::my-destination-bucket",
            "ExpectedBucketOwner": "123456789012",
            "CompressionType": "GZIP",
            "StorageClass": "STANDARD"
        }
    }'

命令會傳回頻道 ARN (ChannelARN)。將其與 搭配使用describe-channel，以驗證交付是否達到 ACTIVE 狀態。請參閱 描述 Amazon S3 交付。若要自訂 Amazon S3 物件金鑰結構，請參閱 Amazon S3 交付的 S3 輸出金鑰範本。

API 參考 – 請參閱《Amazon Kinesis Data Streams API 參考CreateChannel》中的 。