Contoh Kinesis menggunakan AWS CLI - AWS Contoh Kode SDK
Tindakan

Ada lebih banyak contoh AWS SDK yang tersedia di repo Contoh SDK AWS Doc. GitHub

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Contoh Kinesis menggunakan AWS CLI

Contoh kode berikut menunjukkan cara melakukan tindakan dan mengimplementasikan skenario umum dengan menggunakan AWS Command Line Interface Kinesis with.

Tindakan merupakan kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Sementara tindakan menunjukkan cara memanggil fungsi layanan individual, Anda dapat melihat tindakan dalam konteks dalam skenario terkait.

Setiap contoh menyertakan tautan ke kode sumber lengkap, di mana Anda dapat menemukan instruksi tentang cara mengatur dan menjalankan kode dalam konteks.

Tindakan

Contoh kode berikut menunjukkan cara menggunakanadd-tags-to-stream.

AWS CLI

Untuk menambahkan tag ke aliran data

add-tags-to-streamContoh berikut memberikan tag dengan kunci samplekey dan nilai example untuk aliran tertentu.

aws kinesis add-tags-to-stream \
    --stream-name samplestream \
    --tags samplekey=example

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Menandai Streaming Anda di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakancreate-stream.

AWS CLI

Untuk membuat aliran data

create-streamContoh berikut membuat aliran data bernama samplestream dengan 3 pecahan.

aws kinesis create-stream \
    --stream-name samplestream \
    --shard-count 3

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Membuat Stream di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat CreateStreamdi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakandecrease-stream-retention-period.

AWS CLI

Untuk mengurangi periode retensi aliran data

decrease-stream-retention-periodContoh berikut mengurangi periode retensi (lamanya waktu catatan data dapat diakses setelah ditambahkan ke aliran) dari aliran bernama samplestream hingga 48 jam.

aws kinesis decrease-stream-retention-period \
    --stream-name samplestream \
    --retention-period-hours 48

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Mengubah Periode Retensi Data di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakandelete-stream.

AWS CLI

Untuk menghapus aliran data

delete-streamContoh berikut menghapus aliran data yang ditentukan.

aws kinesis delete-stream \
    --stream-name samplestream

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Menghapus Stream di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat DeleteStreamdi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakanderegister-stream-consumer.

AWS CLI

Untuk membatalkan pendaftaran konsumen aliran data

deregister-stream-consumerContoh berikut membatalkan pendaftaran konsumen tertentu dari aliran data yang ditentukan.

aws kinesis deregister-stream-consumer \
    --stream-arn arn:aws:kinesis:us-west-2:123456789012:stream/samplestream \
    --consumer-name KinesisConsumerApplication

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Mengembangkan Konsumen dengan Fan-Out yang Ditingkatkan Menggunakan API Aliran Data Kinesis di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakandescribe-limits.

AWS CLI

Untuk menggambarkan batas pecahan

describe-limitsContoh berikut menampilkan batas pecahan dan penggunaan untuk AWS akun saat ini.

aws kinesis describe-limits

Output:

{
    "ShardLimit": 500,
    "OpenShardCount": 29
}

Untuk informasi selengkapnya, lihat Mengubah Ulang Stream di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat DescribeLimitsdi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakandescribe-stream-consumer.

AWS CLI

Untuk menggambarkan konsumen aliran data

describe-stream-consumerContoh berikut mengembalikan deskripsi konsumen tertentu, terdaftar dengan aliran data yang ditentukan.

aws kinesis describe-stream-consumer \
    --stream-arn arn:aws:kinesis:us-west-2:012345678912:stream/samplestream \
    --consumer-name KinesisConsumerApplication

Output:

{
    "ConsumerDescription": {
        "ConsumerName": "KinesisConsumerApplication",
        "ConsumerARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream/consumer/KinesisConsumerApplication:1572383852",
        "ConsumerStatus": "ACTIVE",
        "ConsumerCreationTimestamp": 1572383852.0,
        "StreamARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream"
    }
}

Untuk informasi selengkapnya, lihat Membaca Data dari Amazon Kinesis Data Streams di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakandescribe-stream-summary.

AWS CLI

Untuk menggambarkan ringkasan aliran data

describe-stream-summaryContoh berikut memberikan deskripsi yang diringkas (tanpa daftar pecahan) dari aliran data yang ditentukan.

aws kinesis describe-stream-summary \
    --stream-name samplestream

Output:

{
    "StreamDescriptionSummary": {
        "StreamName": "samplestream",
        "StreamARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream",
        "StreamStatus": "ACTIVE",
        "RetentionPeriodHours": 48,
        "StreamCreationTimestamp": 1572297168.0,
        "EnhancedMonitoring": [
            {
                "ShardLevelMetrics": []
            }
        ],
        "EncryptionType": "NONE",
        "OpenShardCount": 3,
        "ConsumerCount": 0
    }
}

Untuk informasi selengkapnya, lihat Membuat dan Mengelola Streaming di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakandescribe-stream.

AWS CLI

Untuk menggambarkan aliran data

describe-streamContoh berikut mengembalikan rincian aliran data yang ditentukan.

aws kinesis describe-stream \
    --stream-name samplestream

Output:

{
    "StreamDescription": {
        "Shards": [
            {
                "ShardId": "shardId-000000000000",
                "HashKeyRange": {
                    "StartingHashKey": "0",
                    "EndingHashKey": "113427455640312821154458202477256070484"
                },
                "SequenceNumberRange": {
                    "StartingSequenceNumber": "49600871682957036442365024926191073437251060580128653314"
                }
            },
            {
                "ShardId": "shardId-000000000001",
                "HashKeyRange": {
                    "StartingHashKey": "113427455640312821154458202477256070485",
                    "EndingHashKey": "226854911280625642308916404954512140969"
                },
                "SequenceNumberRange": {
                    "StartingSequenceNumber": "49600871682979337187563555549332609155523708941634633746"
                }
            },
            {
                "ShardId": "shardId-000000000002",
                "HashKeyRange": {
                    "StartingHashKey": "226854911280625642308916404954512140970",
                    "EndingHashKey": "340282366920938463463374607431768211455"
                },
                "SequenceNumberRange": {
                    "StartingSequenceNumber": "49600871683001637932762086172474144873796357303140614178"
                }
            }
        ],
        "StreamARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream",
        "StreamName": "samplestream",
        "StreamStatus": "ACTIVE",
        "RetentionPeriodHours": 24,
        "EnhancedMonitoring": [
            {
                "ShardLevelMetrics": []
            }
        ],
        "EncryptionType": "NONE",
        "KeyId": null,
        "StreamCreationTimestamp": 1572297168.0
    }
}

Untuk informasi selengkapnya, lihat Membuat dan Mengelola Streaming di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat DescribeStreamdi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakandisable-enhanced-monitoring.

AWS CLI

Untuk menonaktifkan pemantauan yang disempurnakan untuk metrik tingkat shard

disable-enhanced-monitoringContoh berikut menonaktifkan pemantauan aliran data Kinesis yang disempurnakan untuk metrik tingkat shard.

aws kinesis disable-enhanced-monitoring \
    --stream-name samplestream --shard-level-metrics ALL

Output:

{
    "StreamName": "samplestream",
    "CurrentShardLevelMetrics": [
        "IncomingBytes",
        "OutgoingRecords",
        "IteratorAgeMilliseconds",
        "IncomingRecords",
        "ReadProvisionedThroughputExceeded",
        "WriteProvisionedThroughputExceeded",
        "OutgoingBytes"
    ],
    "DesiredShardLevelMetrics": []
}

Untuk informasi selengkapnya, lihat Memantau Aliran di Amazon Kinesis Data Streams di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakanenable-enhanced-monitoring.

AWS CLI

Untuk mengaktifkan pemantauan yang disempurnakan untuk metrik tingkat shard

enable-enhanced-monitoringContoh berikut memungkinkan pemantauan aliran data Kinesis yang disempurnakan untuk metrik tingkat shard.

aws kinesis enable-enhanced-monitoring \
    --stream-name samplestream \
    --shard-level-metrics ALL

Output:

{
    "StreamName": "samplestream",
    "CurrentShardLevelMetrics": [],
    "DesiredShardLevelMetrics": [
        "IncomingBytes",
        "OutgoingRecords",
        "IteratorAgeMilliseconds",
        "IncomingRecords",
        "ReadProvisionedThroughputExceeded",
        "WriteProvisionedThroughputExceeded",
        "OutgoingBytes"
    ]
}

Untuk informasi selengkapnya, lihat Memantau Aliran di Amazon Kinesis Data Streams di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakanget-records.

AWS CLI

Untuk mendapatkan catatan dari pecahan

get-recordsContoh berikut mendapatkan catatan data dari pecahan Kinesis aliran data menggunakan iterator shard tertentu.

aws kinesis get-records \
    --shard-iterator AAAAAAAAAAF7/0mWD7IuHj1yGv/TKuNgx2ukD5xipCY4cy4gU96orWwZwcSXh3K9tAmGYeOZyLZrvzzeOFVf9iN99hUPw/w/b0YWYeehfNvnf1DYt5XpDJghLKr3DzgznkTmMymDP3R+3wRKeuEw6/kdxY2yKJH0veaiekaVc4N2VwK/GvaGP2Hh9Fg7N++q0Adg6fIDQPt4p8RpavDbk+A4sL9SWGE1

Output:

{
    "Records": [],
    "MillisBehindLatest": 80742000
}

Untuk informasi selengkapnya, lihat Mengembangkan Konsumen Menggunakan API Kinesis Data Streams AWS dengan SDK for Java di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat GetRecordsdi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakanget-shard-iterator.

AWS CLI

Untuk mendapatkan iterator shard

get-shard-iteratorContoh berikut menggunakan tipe iterator AT_SEQUENCE_NUMBER shard dan menghasilkan iterator shard untuk mulai membaca catatan data persis dari posisi yang dilambangkan dengan nomor urut yang ditentukan.

aws kinesis get-shard-iterator \
    --stream-name samplestream \
    --shard-id shardId-000000000001 \
    --shard-iterator-type LATEST

Output:

{
    "ShardIterator": "AAAAAAAAAAFEvJjIYI+3jw/4aqgH9FifJ+n48XWTh/IFIsbILP6o5eDueD39NXNBfpZ10WL5K6ADXk8w+5H+Qhd9cFA9k268CPXCz/kebq1TGYI7Vy+lUkA9BuN3xvATxMBGxRY3zYK05gqgvaIRn94O8SqeEqwhigwZxNWxID3Ej7YYYcxQi8Q/fIrCjGAy/n2r5Z9G864YpWDfN9upNNQAR/iiOWKs"
}

Untuk informasi selengkapnya, lihat Mengembangkan Konsumen Menggunakan API Kinesis Data Streams AWS dengan SDK for Java di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakanincrease-stream-retention-period.

AWS CLI

Untuk meningkatkan periode retensi aliran data

increase-stream-retention-periodContoh berikut meningkatkan periode retensi (lamanya waktu catatan data dapat diakses setelah ditambahkan ke aliran) dari aliran yang ditentukan menjadi 168 jam.

aws kinesis increase-stream-retention-period \
    --stream-name samplestream \
    --retention-period-hours 168

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Mengubah Periode Retensi Data di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakanlist-shards.

AWS CLI

Untuk daftar pecahan dalam aliran data

list-shardsContoh berikut mencantumkan semua pecahan dalam aliran yang ditentukan dimulai dengan pecahan yang IDnya segera mengikuti yang ditentukan exclusive-start-shard-id dari. shardId-000000000000

aws kinesis list-shards \
    --stream-name samplestream \
    --exclusive-start-shard-id shardId-000000000000

Output:

{
    "Shards": [
        {
            "ShardId": "shardId-000000000001",
            "HashKeyRange": {
                "StartingHashKey": "113427455640312821154458202477256070485",
                "EndingHashKey": "226854911280625642308916404954512140969"
            },
            "SequenceNumberRange": {
                "StartingSequenceNumber": "49600871682979337187563555549332609155523708941634633746"
            }
        },
        {
            "ShardId": "shardId-000000000002",
            "HashKeyRange": {
                "StartingHashKey": "226854911280625642308916404954512140970",
                "EndingHashKey": "340282366920938463463374607431768211455"
            },
            "SequenceNumberRange": {
                "StartingSequenceNumber": "49600871683001637932762086172474144873796357303140614178"
            }
        }
    ]
}

Untuk informasi selengkapnya, lihat Daftar Pecahan di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat ListShardsdi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakanlist-streams.

AWS CLI

Untuk membuat daftar aliran data

list-streamsContoh berikut mencantumkan semua aliran data aktif di akun dan wilayah saat ini.

aws kinesis list-streams

Output:

{
    "StreamNames": [
        "samplestream",
        "samplestream1"
    ]
}

Untuk informasi selengkapnya, lihat Daftar Aliran di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat ListStreamsdi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakanlist-tags-for-stream.

AWS CLI

Untuk daftar tag untuk aliran data

list-tags-for-streamContoh berikut mencantumkan tag yang dilampirkan ke aliran data yang ditentukan.

aws kinesis list-tags-for-stream \
    --stream-name samplestream

Output:

{
    "Tags": [
        {
            "Key": "samplekey",
            "Value": "example"
        }
    ],
    "HasMoreTags": false
}

Untuk informasi selengkapnya, lihat Menandai Streaming Anda di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakanmerge-shards.

AWS CLI

Untuk menggabungkan pecahan

merge-shardsContoh berikut menggabungkan dua pecahan yang berdekatan dengan Shardid-000000000000 IDs dan ShardID-0000000001 dalam aliran data yang ditentukan dan menggabungkannya menjadi pecahan tunggal.

aws kinesis merge-shards \
    --stream-name samplestream \
    --shard-to-merge shardId-000000000000 \
    --adjacent-shard-to-merge shardId-000000000001

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Menggabungkan Dua Pecahan di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat MergeShardsdi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakanput-record.

AWS CLI

Untuk menulis catatan ke dalam aliran data

put-recordContoh berikut menulis catatan data tunggal ke dalam aliran data yang ditentukan menggunakan kunci partisi yang ditentukan.

aws kinesis put-record \
    --stream-name samplestream \
    --data sampledatarecord \
    --partition-key samplepartitionkey

Output:

{
    "ShardId": "shardId-000000000009",
    "SequenceNumber": "49600902273357540915989931256901506243878407835297513618",
    "EncryptionType": "KMS"
}

Untuk informasi selengkapnya, lihat Mengembangkan Produsen Menggunakan API Amazon Kinesis Data Streams AWS dengan SDK for Java di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat PutRecorddi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakanput-records.

AWS CLI

Untuk menulis beberapa catatan ke dalam aliran data

put-recordsContoh berikut menulis catatan data menggunakan kunci partisi yang ditentukan dan catatan data lain menggunakan kunci partisi yang berbeda dalam satu panggilan.

aws kinesis put-records \
    --stream-name samplestream \
    --records Data=blob1,PartitionKey=partitionkey1 Data=blob2,PartitionKey=partitionkey2

Output:

{
    "FailedRecordCount": 0,
    "Records": [
        {
            "SequenceNumber": "49600883331171471519674795588238531498465399900093808706",
            "ShardId": "shardId-000000000004"
        },
        {
            "SequenceNumber": "49600902273357540915989931256902715169698037101720764562",
            "ShardId": "shardId-000000000009"
        }
    ],
    "EncryptionType": "KMS"
}

Untuk informasi selengkapnya, lihat Mengembangkan Produsen Menggunakan API Amazon Kinesis Data Streams AWS dengan SDK for Java di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat PutRecordsdi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakanregister-stream-consumer.

AWS CLI

Untuk mendaftarkan konsumen aliran data

register-stream-consumerContoh berikut mendaftarkan konsumen yang dipanggil KinesisConsumerApplication dengan aliran data yang ditentukan.

aws kinesis register-stream-consumer \
    --stream-arn arn:aws:kinesis:us-west-2:012345678912:stream/samplestream \
    --consumer-name KinesisConsumerApplication

Output:

{
    "Consumer": {
        "ConsumerName": "KinesisConsumerApplication",
        "ConsumerARN": "arn:aws:kinesis:us-west-2: 123456789012:stream/samplestream/consumer/KinesisConsumerApplication:1572383852",
        "ConsumerStatus": "CREATING",
        "ConsumerCreationTimestamp": 1572383852.0
    }
}

Untuk informasi selengkapnya, lihat Mengembangkan Konsumen dengan Fan-Out yang Ditingkatkan Menggunakan API Aliran Data Kinesis di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakanremove-tags-from-stream.

AWS CLI

Untuk menghapus tag dari aliran data

remove-tags-from-streamContoh berikut menghapus tag dengan kunci yang ditentukan dari aliran data yang ditentukan.

aws kinesis remove-tags-from-stream \
    --stream-name samplestream \
    --tag-keys samplekey

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Menandai Streaming Anda di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakansplit-shard.

AWS CLI

Untuk membagi pecahan

split-shardContoh berikut membagi pecahan yang ditentukan menjadi dua pecahan baru menggunakan kunci hash awal baru 10.

aws kinesis split-shard \
    --stream-name samplestream \
    --shard-to-split shardId-000000000000 \
    --new-starting-hash-key 10

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Memisahkan Shard di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat SplitSharddi Referensi AWS CLI Perintah.

Contoh kode berikut menunjukkan cara menggunakanstart-stream-encryption.

AWS CLI

Untuk mengaktifkan enkripsi aliran data

start-stream-encryptionContoh berikut memungkinkan enkripsi sisi server untuk aliran tertentu, menggunakan kunci KMS yang ditentukan AWS .

aws kinesis start-stream-encryption \
    --encryption-type KMS \
    --key-id arn:aws:kms:us-west-2:012345678912:key/a3c4a7cd-728b-45dd-b334-4d3eb496e452 \
    --stream-name samplestream

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Perlindungan Data di Amazon Kinesis Data Streams di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakanstop-stream-encryption.

AWS CLI

Untuk menonaktifkan enkripsi aliran data

stop-stream-encryptionContoh berikut menonaktifkan enkripsi sisi server untuk aliran tertentu, menggunakan kunci KMS yang ditentukan. AWS 

aws kinesis start-stream-encryption \
    --encryption-type KMS \
    --key-id arn:aws:kms:us-west-2:012345678912:key/a3c4a7cd-728b-45dd-b334-4d3eb496e452 \
    --stream-name samplestream

Perintah ini tidak menghasilkan output.

Untuk informasi selengkapnya, lihat Perlindungan Data di Amazon Kinesis Data Streams di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakanupdate-shard-count.

AWS CLI

Untuk memperbarui jumlah pecahan dalam aliran data

update-shard-countContoh berikut memperbarui jumlah pecahan dari aliran data yang ditentukan ke 6. Contoh ini menggunakan penskalaan seragam, yang menciptakan pecahan dengan ukuran yang sama.

aws kinesis update-shard-count \
    --stream-name samplestream \
    --scaling-type UNIFORM_SCALING \
    --target-shard-count 6

Output:

{
    "StreamName": "samplestream",
    "CurrentShardCount": 3,
    "TargetShardCount": 6
}

Untuk informasi selengkapnya, lihat Mengubah Ulang Stream di Panduan Pengembang Amazon Kinesis Data Streams.