与 AWS SDK或GetShardIterator一起使用 CLI - AWS SDK代码示例

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

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

与 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" }

有关更多信息,请参阅亚马逊 Kinesis Data Streams 开发者指南 AWS SDK》中的使用 Kinesis Data API Streams 和 Java 版开发消费者

PowerShell
用于 PowerShell

示例 1:返回指定分片和起始位置的分片迭代器。通过引用返回的流对象的 Shards 集合,可以从 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 参考GetShardIterator中的。