Utilisation de GetShardIterator avec une CLI - Exemples de code de kit AWS SDK

D’autres exemples de kits AWS SDK sont disponibles dans le référentiel GitHub AWS Doc SDK Examples.

Utilisation de GetShardIterator avec une CLI

Les exemples de code suivants illustrent comment utiliser GetShardIterator.

Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :

CLI
AWS CLI

Pour obtenir un itérateur de partition

L’exemple get-shard-iterator suivant utilise le type d’itérateur de partition AT_SEQUENCE_NUMBER et génère un itérateur de partition pour commencer à lire les enregistrements de données exactement à partir de la position indiquée par le numéro de séquence spécifié.

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

Sortie :

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

Pour plus d’informations, consultez Développement d’applications consommateur à l’aide de l’API Kinesis Data Streams avec le kit AWS SDK pour Java dans le Guide du développeur Amazon Kinesis Data Streams.

  • Pour plus de détails sur l’API, consultez GetShardIterator dans la Référence des commandes de l’AWS CLI.

PowerShell
Outils pour PowerShell V4

Exemple 1 : renvoie un itérateur de partition pour la partition et la position de départ spécifiées. Les détails des identificateurs de partition et des numéros de séquence peuvent être obtenus à partir de la sortie de l’applet de commande Get-KINStream, en faisant référence à la collection Shards de l’objet de flux renvoyé. L’itérateur renvoyé peut être utilisé avec l’applet de commande Get-KINRecord pour extraire des enregistrements de données dans la partition.

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

Sortie :

AAAAAAAAAAGIc....9VnbiRNaP

  • Pour plus de détails sur l’API, consultez GetShardIterator dans la Référence des applets de commande pour les Outils AWS pour PowerShell (V4).

Outils pour PowerShell V5

Exemple 1 : renvoie un itérateur de partition pour la partition et la position de départ spécifiées. Les détails des identificateurs de partition et des numéros de séquence peuvent être obtenus à partir de la sortie de l’applet de commande Get-KINStream, en faisant référence à la collection Shards de l’objet de flux renvoyé. L’itérateur renvoyé peut être utilisé avec l’applet de commande Get-KINRecord pour extraire des enregistrements de données dans la partition.

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

Sortie :

AAAAAAAAAAGIc....9VnbiRNaP

  • Pour plus de détails sur l’API, consultez GetShardIterator dans la Référence des applets de commande pour les Outils AWS pour PowerShell (V5).