Tools for PowerShell를 사용한 Kinesis 예제 - AWS SDK 코드 예제
작업

AWS Doc SDK ExamplesWord AWS SDK 리포지토리에는 더 많은 GitHub 예제가 있습니다.

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

Tools for PowerShell를 사용한 Kinesis 예제

다음 코드 예제에서는 Kinesis와 AWS Tools for PowerShell 함께를 사용하여 작업을 수행하고 일반적인 시나리오를 구현하는 방법을 보여줍니다.

작업은 대규모 프로그램에서 발췌한 코드이며 컨텍스트에 맞춰 실행해야 합니다. 작업은 개별 서비스 함수를 직접적으로 호출하는 방법을 보여주며 관련 시나리오의 컨텍스트에 맞는 작업을 볼 수 있습니다.

각 예제에는 컨텍스트에서 코드를 설정하고 실행하는 방법에 대한 지침을 찾을 수 있는 전체 소스 코드에 대한 링크가 포함되어 있습니다.

주제

작업

다음 코드 예시에서는 Get-KINRecord을 사용하는 방법을 보여 줍니다.

for PowerShell 도구

예제 1: 이 예제에서는 일련의 하나 이상 레코드에서 데이터를 반환 및 추출하는 방법을 보여줍니다. 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 세부 정보는 AWS Tools for PowerShell Cmdlet 참조의 GetRecords를 참조하세요.

다음 코드 예시에서는 Get-KINShardIterator을 사용하는 방법을 보여 줍니다.

for PowerShell 도구

예제 1: 지정된 샤드 및 시작 위치에 대한 샤드 반복자를 반환합니다. 샤드 식별자 및 시퀀스 번호에 대한 세부 정보는 반환된 스트림 객체의 샤드 컬렉션을 참조하여 Get-KINStream cmdlet의 출력에서 얻을 수 있습니다. 반환된 반복기를 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를 참조하세요.