Tools for を使用した Kinesis の例 PowerShell - AWS SDK CLI コードの例
アクション

AWS Doc SDK Examples GitHub リポジトリには他にも AWS SDK例があります。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Tools for を使用した Kinesis の例 PowerShell

次のコード例は、Kinesis AWS Tools for PowerShell で を使用してアクションを実行し、一般的なシナリオを実装する方法を示しています。

アクションはより大きなプログラムからのコードの抜粋であり、コンテキスト内で実行する必要があります。アクションは個々のサービス機能を呼び出す方法を示していますが、コンテキスト内のアクションは、関連するシナリオで確認できます。

各例には、完全なソースコードへのリンクが含まれており、コンテキスト内でコードを設定して実行する方法の手順を確認できます。

トピック

アクション

次の例は、Get-KINRecord を使用する方法を説明しています。

のツール PowerShell

例 1: この例では、一連の 1 つ以上のレコードからデータを返して抽出する方法を示しています。に供給されたイテレーターは、この例のどのレコードが変数 $records にキャプチャされるかを返すレコードの開始位置 Get-KINRecord を決定します。その後、$records コレクションにインデックスを付けることで、個々のレコードにアクセスできます。レコード内のデータが UTF-8 でエンコードされたテキストであるとすると、最後のコマンドは、 オブジェクト MemoryStream の からデータを抽出し、テキストとしてコンソールに返す方法を示します。

$records
$records = Get-KINRecord -ShardIterator "AAAAAAAAAAGIc....9VnbiRNaP"

出力:

MillisBehindLatest NextShardIterator            Records
------------------ -----------------            -------
0                  AAAAAAAAAAERNIq...uDn11HuUs  {Key1, Key2}
$records.Records[0]

出力:

ApproximateArrivalTimestamp Data                   PartitionKey SequenceNumber
--------------------------- ----                   ------------ --------------
3/7/2016 5:14:33 PM         System.IO.MemoryStream Key1         4955986459776...931586
[Text.Encoding]::UTF8.GetString($records.Records[0].Data.ToArray())

出力:

test data from string

  • API 詳細については、「 コマンドレットリファレンスGetRecords」の「」を参照してください。 AWS Tools for PowerShell

次の例は、Get-KINShardIterator を使用する方法を説明しています。

のツール PowerShell

例 1: 指定されたシャードと開始位置のシャードイテレータを返します。シャード識別子とシーケンス番号の詳細は、返されたストリームオブジェクトのシャードコレクションを参照することで、 Get-KINStream コマンドレットの出力から取得できます。返されたイテレーターを Get-KINRecord コマンドレットとともに使用して、シャード内のデータレコードをプルできます。

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

出力:

AAAAAAAAAAGIc....9VnbiRNaP

  • API 詳細については、「 コマンドレットリファレンスGetShardIterator」の「」を参照してください。 AWS Tools for PowerShell

次の例は、Get-KINStream を使用する方法を説明しています。

のツール PowerShell

例 1: 指定されたストリームの詳細を返します。

Get-KINStream -StreamName "mystream"

出力:

HasMoreShards        : False
RetentionPeriodHours : 24
Shards               : {}
StreamARN            : arn:aws:kinesis:us-west-2:123456789012:stream/mystream
StreamName           : mystream
StreamStatus         : ACTIVE

  • API 詳細については、「 コマンドレットリファレンスDescribeStream」の「」を参照してください。 AWS Tools for PowerShell

次のコード例は、New-KINStream を使用する方法を示しています。

のツール PowerShell

例 1: 新しいストリームを作成します。デフォルトでは、このコマンドレットは出力を返さないため、後で使用できるように - StreamName パラメータに指定された値を返すために - PassThru スイッチが追加されます。

$streamName = New-KINStream -StreamName "mystream" -ShardCount 1 -PassThru

  • API 詳細については、「 コマンドレットリファレンスCreateStream」の「」を参照してください。 AWS Tools for PowerShell

次のコード例は、Remove-KINStream を使用する方法を示しています。

のツール PowerShell

例 1: 指定されたストリームを削除します。コマンドを実行する前に確認を求められます。確認メッセージを非表示にするには -Force スイッチを使用します。

Remove-KINStream -StreamName "mystream"

  • API 詳細については、「 コマンドレットリファレンスDeleteStream」の「」を参照してください。 AWS Tools for PowerShell

次のコード例は、Write-KINRecord を使用する方法を示しています。

のツール PowerShell

例 1: -Text パラメータに指定された文字列を含むレコードを書き込みます。

Write-KINRecord -Text "test data from string" -StreamName "mystream" -PartitionKey "Key1"

例 2: 指定されたファイルに含まれるデータを含むレコードを書き込みます。ファイルはバイトのシーケンスとして扱われるため、テキストが含まれている場合は、このコマンドレットで使用する前に、必要なエンコードで記述する必要があります。

Write-KINRecord -FilePath "C:\TestData.txt" -StreamName "mystream" -PartitionKey "Key2"

  • API 詳細については、「 コマンドレットリファレンスPutRecord」の「」を参照してください。 AWS Tools for PowerShell