Contoh Kinesis menggunakan Alat untuk V5 PowerShell

Contoh 1: Contoh ini menunjukkan cara mengembalikan dan mengekstrak data dari serangkaian satu atau lebih catatan. Pemasok iterator untuk Get-KINRecord menentukan posisi awal dari catatan yang akan dikembalikan yang dalam contoh ini ditangkap menjadi variabel, $records. Setiap catatan individu kemudian dapat diakses dengan mengindeks koleksi $records. Dengan asumsi data dalam catatan adalah teks yang UTF-8 dikodekan, perintah terakhir menunjukkan bagaimana Anda dapat mengekstrak data dari MemoryStream dalam objek dan mengembalikannya sebagai teks ke konsol.

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

Output:

MillisBehindLatest NextShardIterator            Records
------------------ -----------------            -------
0                  AAAAAAAAAAERNIq...uDn11HuUs  {Key1, Key2}

$records.Records[0]

Output:

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())

Output:

test data from string

Contoh 1: Mengembalikan iterator shard untuk pecahan dan posisi awal yang ditentukan. Rincian pengidentifikasi pecahan dan nomor urutan dapat diperoleh dari output Get-KINStream cmdlet, dengan mereferensikan koleksi Shards dari objek aliran yang dikembalikan. Iterator yang dikembalikan dapat digunakan dengan Get-KINRecord cmdlet untuk menarik catatan data di shard.

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

Output:

AAAAAAAAAAGIc....9VnbiRNaP

Contoh 1: Mengembalikan rincian aliran yang ditentukan.

Get-KINStream -StreamName "mystream"

Output:

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

Contoh 1: Membuat aliran baru.

New-KINStream -StreamName "mystream" -ShardCount 1

Contoh 1: Menghapus aliran yang ditentukan. Anda diminta untuk konfirmasi sebelum perintah dieksekusi. Untuk menekan permintaan konfirmasi gunakan sakelar -Force.

Remove-KINStream -StreamName "mystream"

Contoh 1: Menulis catatan yang berisi string yang diberikan ke parameter -Text.

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

Contoh 2: Menulis catatan yang berisi data yang terkandung dalam file yang ditentukan. File diperlakukan sebagai urutan byte jadi jika berisi teks, itu harus ditulis dengan pengkodean yang diperlukan sebelum menggunakannya dengan cmdlet ini.

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