将 GetShardIterator 与 CLI 配合使用 - AWS SDK 代码示例

AWS 文档 SDK 示例 GitHub 存储库中还有更多 AWS SDK 示例。

将 GetShardIterator 与 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 开发人员指南》中的通过 AWS SDK for Java 使用 Kinesis Data Streams API 开发消费端。

  • 有关 API 详细信息，请参阅《AWS CLI 命令参考》中的 GetShardIterator。

PowerShell
Tools for PowerShell V4

示例 1：返回指定分片和起始位置的分片迭代器。通过引用返回的流对象的分片集合，可以从 Get-KINStream cmdlet 的输出中获取分片标识符和序列号的详细信息。返回的迭代器可以与 Get-KINRecord cmdlet 搭配使用，用于在分片中提取数据记录。

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

输出：

AAAAAAAAAAGIc....9VnbiRNaP

  • 有关 API 详细信息，请参阅《AWS Tools for PowerShell Cmdlet Reference (V4)》中的 GetShardIterator。

Tools for PowerShell V5

示例 1：返回指定分片和起始位置的分片迭代器。通过引用返回的流对象的分片集合，可以从 Get-KINStream cmdlet 的输出中获取分片标识符和序列号的详细信息。返回的迭代器可以与 Get-KINRecord cmdlet 搭配使用，用于在分片中提取数据记录。

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

输出：

AAAAAAAAAAGIc....9VnbiRNaP

  • 有关 API 详细信息，请参阅《AWS Tools for PowerShell Cmdlet Reference (V5)》中的 GetShardIterator。