Cookie の設定を選択する

当社は、当社のサイトおよびサービスを提供するために必要な必須 Cookie および類似のツールを使用しています。当社は、パフォーマンス Cookie を使用して匿名の統計情報を収集することで、お客様が当社のサイトをどのように利用しているかを把握し、改善に役立てています。必須 Cookie は無効化できませんが、[カスタマイズ] または [拒否] をクリックしてパフォーマンス Cookie を拒否することはできます。

お客様が同意した場合、AWS および承認された第三者は、Cookie を使用して便利なサイト機能を提供したり、お客様の選択を記憶したり、関連する広告を含む関連コンテンツを表示したりします。すべての必須ではない Cookie を受け入れるか拒否するには、[受け入れる] または [拒否] をクリックしてください。より詳細な選択を行うには、[カスタマイズ] をクリックしてください。

Tools for PowerShell を使用した Kinesis の例

フォーカスモード
Tools for PowerShell を使用した Kinesis の例 - AWS SDK コードの例

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

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

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

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

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

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

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

トピック

アクション

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

Tools for PowerShell

例 1: この例では、一連の 1 つ以上のレコードからデータを返して抽出する方法を示しています。Get-KINRecord に供給されたイテレータは、この例で変数 $records にキャプチャされるレコードの開始位置を決定します。その後、$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 の詳細については、「AWS Tools for PowerShell Cmdlet リファレンス」の「GetRecords」を参照してください。

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

Tools for PowerShell

例 1: この例では、一連の 1 つ以上のレコードからデータを返して抽出する方法を示しています。Get-KINRecord に供給されたイテレータは、この例で変数 $records にキャプチャされるレコードの開始位置を決定します。その後、$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 の詳細については、「AWS Tools for PowerShell Cmdlet リファレンス」の「GetRecords」を参照してください。

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

Tools for PowerShell

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

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

出力:

AAAAAAAAAAGIc....9VnbiRNaP
  • API の詳細については、「AWS Tools for PowerShell Cmdlet リファレンス」の「GetShardIterator」を参照してください。

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

Tools for PowerShell

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

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

出力:

AAAAAAAAAAGIc....9VnbiRNaP
  • API の詳細については、「AWS Tools for PowerShell Cmdlet リファレンス」の「GetShardIterator」を参照してください。

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

Tools for 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 の詳細については、「AWS Tools for PowerShell コマンドレットリファレンス」の「DescribeStream」を参照してください。

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

Tools for 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 の詳細については、「AWS Tools for PowerShell コマンドレットリファレンス」の「DescribeStream」を参照してください。

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

Tools for PowerShell

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

$streamName = New-KINStream -StreamName "mystream" -ShardCount 1 -PassThru
  • API の詳細については、「AWS Tools for PowerShell コマンドレットリファレンス」の「CreateStream」を参照してください。

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

Tools for PowerShell

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

$streamName = New-KINStream -StreamName "mystream" -ShardCount 1 -PassThru
  • API の詳細については、「AWS Tools for PowerShell コマンドレットリファレンス」の「CreateStream」を参照してください。

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

Tools for PowerShell

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

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

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

Tools for PowerShell

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

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

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

Tools for 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 の詳細については、「AWS Tools for PowerShell コマンドレットリファレンス」の「PutRecord」を参照してください。

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

Tools for 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 の詳細については、「AWS Tools for PowerShell コマンドレットリファレンス」の「PutRecord」を参照してください。

このページの内容

プライバシーサイト規約Cookie の設定
© 2025, Amazon Web Services, Inc. or its affiliates.All rights reserved.