使用 Tools for PowerShell 的 Kinesis 範例 - AWS SDK 程式碼範例
動作

文件 AWS SDK AWS 範例 SDK 儲存庫中有更多可用的 GitHub 範例。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

使用 Tools for PowerShell 的 Kinesis 範例

下列程式碼範例示範如何搭配 AWS Tools for PowerShell Kinesis 使用 來執行動作和實作常見案例。

Actions 是大型程式的程式碼摘錄，必須在內容中執行。雖然 動作會示範如何呼叫個別服務函數，但您可以在其相關案例中查看內容中的動作。

每個範例都包含完整原始程式碼的連結，您可以在其中找到如何在內容中設定和執行程式碼的指示。

主題

動作

下列程式碼範例示範如何使用 Get-KINRecord。

for PowerShell 工具

範例 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。

for PowerShell 工具

範例 1：傳回指定碎片和起始位置的碎片迭代器。碎片識別符和序號的詳細資訊可從 Get-KINStream cmdlet 的輸出取得，方法是參考傳回串流物件的 Shards 集合。傳回的迭代器可與 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。

下列程式碼範例示範如何使用 Get-KINStream。

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 Cmdlet 參考中的 DescribeStream。

下列程式碼範例示範如何使用 New-KINStream。

for PowerShell 工具

範例 1：建立新的串流。根據預設，此 cmdlet 不會傳回任何輸出，因此會新增 -PassThru 開關，以傳回提供給 -StreamName 參數的值，以供後續使用。

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

  • 如需 API 詳細資訊，請參閱 AWS Tools for PowerShell Cmdlet 參考中的 CreateStream。

下列程式碼範例示範如何使用 Remove-KINStream。

for PowerShell 工具

範例 1：刪除指定的串流。在命令執行之前，系統會提示您進行確認。若要隱藏確認提示，請使用 -Force 切換。

Remove-KINStream -StreamName "mystream"

  • 如需 API 詳細資訊，請參閱 AWS Tools for PowerShell Cmdlet 參考中的 DeleteStream。

下列程式碼範例示範如何使用 Write-KINRecord。

for PowerShell 工具

範例 1：寫入包含提供給 -Text 參數之字串的記錄。

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

範例 2：寫入包含指定檔案中資料的記錄。檔案會被視為位元組序列，因此如果其中包含文字，則應在搭配此 cmdlet 使用之前，以任何必要的編碼寫入檔案。

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

  • 如需 API 詳細資訊，請參閱 AWS Tools for PowerShell Cmdlet 參考中的 PutRecord。