搭GetShardIterator配 AWS SDK或使用 CLI - AWS SDK 程式碼範例

AWS 文檔 AWS SDK示例 GitHub 回購中有更多SDK示例。

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

搭GetShardIterator配 AWS SDK或使用 CLI

下列程式碼範例會示範如何使用GetShardIterator。

動作範例是大型程式的程式碼摘錄，必須在內容中執行。您可以在下列程式碼範例的內容中看到此動作：

CLI
AWS CLI

獲取碎片迭代器

下列get-shard-iterator範例會使用AT_SEQUENCE_NUMBER碎片迭代器類型，並產生碎片迭代器，以便從指定序號所表示的位置完全開始讀取資料記錄。

aws kinesis get-shard-iterator \
    --stream-name samplestream \
    --shard-id shardId-000000000001 \
    --shard-iterator-type LATEST

輸出：

{
    "ShardIterator": "AAAAAAAAAAFEvJjIYI+3jw/4aqgH9FifJ+n48XWTh/IFIsbILP6o5eDueD39NXNBfpZ10WL5K6ADXk8w+5H+Qhd9cFA9k268CPXCz/kebq1TGYI7Vy+lUkA9BuN3xvATxMBGxRY3zYK05gqgvaIRn94O8SqeEqwhigwZxNWxID3Ej7YYYcxQi8Q/fIrCjGAy/n2r5Z9G864YpWDfN9upNNQAR/iiOWKs"
}

如需詳細資訊，請參閱 Amazon Kinesis Data Streams 開發人員指南中的開發將 Kinesis AWS SDK 資料串流API與 Java 搭配使用的消費者。

  • 如需詳API細資訊，請參閱AWS CLI 指令參考GetShardIterator中的。

PowerShell
適用的工具 PowerShell

實施例 1：返回指定分片和起始位置的碎片迭代器。碎片識別碼和序號的詳細資料可以從 KINStream Get-指令程式的輸出取得，方法是參照傳回之串流物件的碎片集合。傳回的迭代器可與 Get-KINRecord 指令程式搭配使用，以提取碎片中的資料記錄。

Get-KINShardIterator -StreamName "mystream" -ShardId "shardId-000000000000" -ShardIteratorType AT_SEQUENCE_NUMBER -StartingSequenceNumber "495598645..."

輸出：

AAAAAAAAAAGIc....9VnbiRNaP

  • 如需詳API細資訊，請參閱AWS Tools for PowerShell 指令程GetShardIterator式參考中的。