View a markdown version of this page

Contoh kinesis menggunakan AWS CLI - AWS Command Line Interface
Tindakan

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 menerapkan skenario umum dengan menggunakan AWS Command Line Interface dengan Kinesis.

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 menetapkan tag dengan kunci samplekey dan nilai example ke aliran yang ditentukan.

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 CreateStream di Refer AWS CLI ensi 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 catatan data dapat diakses setelah ditambahkan ke aliran) dari aliran bernama samplestream menjadi 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 DeleteStream di Refer AWS CLI ensi Perintah.

Contoh kode berikut menunjukkan cara menggunakanderegister-stream-consumer.

AWS CLI

Untuk membatalkan pendaftaran konsumen aliran data

deregister-stream-consumerContoh berikut membatalkan pendaftaran konsumen yang ditentukan 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 Peningkatan Fan-Out 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 shard dan penggunaan untuk AWS akun saat ini.

aws kinesis describe-limits

Output:

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

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

Contoh kode berikut menunjukkan cara menggunakandescribe-stream-consumer.

AWS CLI

Untuk mendeskripsikan konsumen aliran data

describe-stream-consumerContoh berikut mengembalikan deskripsi konsumen yang ditentukan, 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 mendeskripsikan ringkasan aliran data

describe-stream-summaryContoh berikut memberikan deskripsi ringkasan (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 Ali ran di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakandescribe-stream.

AWS CLI

Untuk mendeskripsikan aliran data

describe-streamContoh berikut mengembalikan detail 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 Ali ran di Panduan Pengembang Amazon Kinesis Data Streams.

Contoh kode berikut menunjukkan cara menggunakandisable-enhanced-monitoring.

AWS CLI

Untuk menonaktifkan pemantauan yang disempurnakan untuk metrik tingkat shard-level

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

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-level

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

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 aliran data Kinesis menggunakan iterator shard yang ditentukan.

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 Kinesis Data Streams API dengan AWS SDK untuk Java di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat GetRecords di Refer AWS CLI ensi 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 tepat 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 Kinesis Data Streams API dengan AWS SDK untuk 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 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 membuat daftar pecahan dalam aliran data

list-shardsContoh berikut mencantumkan semua pecahan dalam aliran yang ditentukan dimulai dengan pecahan yang ID-nya segera mengikuti yang ditentukanexclusive-start-shard-id. 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 ListShards di Refer AWS CLI ensi 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 saat ini dan wilayah.

aws kinesis list-streams

Output:

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

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

  • Untuk detail API, lihat ListStreams di Refer AWS CLI ensi Perintah.

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

AWS CLI

Untuk mencantumkan 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 ID shard Id-000000000000 dan shard Id-000000000001 dalam aliran data yang ditentukan dan menggabungkannya menjadi satu shard.

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 MergeShards di Refer AWS CLI ensi 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 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 Amazon Kinesis Data Streams API dengan AWS SDK untuk Java di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat PutRecord di Refer AWS CLI ensi 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 Amazon Kinesis Data Streams API dengan AWS SDK untuk Java di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat PutRecords di Refer AWS CLI ensi 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 Peningkatan Fan-Out 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 Pecahan di Panduan Pengembang Amazon Kinesis Data Streams.

  • Untuk detail API, lihat SplitShard di Refer AWS CLI ensi Perintah.

Contoh kode berikut menunjukkan cara menggunakanstart-stream-encryption.

AWS CLI

Untuk mengaktifkan enkripsi aliran data

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

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 yang ditentukan, 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 menjadi 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 Membagi Ulang Stream di Panduan Pengembang Amazon Kinesis Data Streams.