本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
從 Amazon Kinesis Data Streams 讀取資料
取用者是處理來自 Kinesis 資料串流的所有資料的應用程式。當消費者使用強化廣發功能時,將取得其自身每秒 2 MB 的讀取傳輸量配額,使得多個消費者能夠並行從同一串流讀取資料,而不必與其他消費者爭用讀取傳輸量。若要使用碎片的強化廣發功能,請參閱開發具有專用輸送量的增強型扇出消費者。
您可以使用 Kinesis Client Library (KCL) 或 為 Kinesis Data Streams 建置取用者 AWS SDK for Java。您也可以使用其他服務開發消費者 AWS Lambda, AWS 例如 Amazon Managed Service for Apache Flink 和 Amazon Data Firehose。Kinesis Data Streams 支援與其他 AWS 服務整合EMR,例如 Amazon、Amazon EventBridge、 AWS Glue和 Amazon Redshift。它也支援第三方整合,包括 Apache Flink、Adobe Experience Platform、Apache Druid、Apache Spark、Databricks、Confluent Platform、Kinesumer 和 Talend。
主題
- 開發具有專用輸送量的增強型扇出消費者
- 在 Kinesis 主控台中使用 Data Viewer
- 在 Kinesis 主控台中查詢您的資料串流
- 使用 Kinesis 用戶端程式庫
- 使用 開發消費者 AWS SDK for Java
- 使用 開發消費者 AWS Lambda
- 使用 Amazon Managed Service for Apache Flink 開發消費者
- 使用 Amazon Data Firehose 開發消費者
- 使用其 AWS 他服務從 Kinesis Data Streams 讀取資料
- 使用第三方整合從 Kinesis Data Streams 讀取資料
- Kinesis Data Streams 消費者疑難排解
- 最佳化 Amazon Kinesis Data Streams 消費者