Memuat data streaming dari Amazon Kinesis Data Streams - OpenSearch Layanan Amazon
Prasyarat

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

Memuat data streaming dari Amazon Kinesis Data Streams

Anda dapat memuat data streaming dari Kinesis Data OpenSearch Streams ke Layanan. Data baru yang tiba di aliran data memicu notifikasi peristiwa untuk Lambda, yang kemudian menjalankan kode kustom Anda untuk melakukan pengindeksan. Bagian ini mencakup kode sampel Python yang kurang modern.

Prasyarat

Sebelum melanjutkan, Anda harus memiliki sumber daya berikut.

Prasyarat Deskripsi
Amazon Kinesis Data Stream Sumber peristiwa untuk fungsi Lambda Anda. Untuk mempelajari selengkapnya, lihat Kinesis Data Streams.
OpenSearch Layanan Domain Tujuan untuk data setelah fungsi Lambda Anda memprosesnya. Untuk informasi selengkapnya, silakan lihat Membuat domain OpenSearch Layanan
IAMPeran

Peran ini harus memiliki izin dasar OpenSearch Layanan, Kinesis, dan Lambda, seperti berikut ini:

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": [
        "es:ESHttpPost",
        "es:ESHttpPut",
        "logs:CreateLogGroup",
        "logs:CreateLogStream",
        "logs:PutLogEvents",
        "kinesis:GetShardIterator",
        "kinesis:GetRecords",
        "kinesis:DescribeStream",
        "kinesis:ListStreams"
      ],
      "Resource": "*"
    }
  ]
}

Peran harus memiliki hubungan kepercayaan berikut:

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Principal": {
        "Service": "lambda.amazonaws.com"
      },
      "Action": "sts:AssumeRole"
    }
  ]
}

Untuk mempelajari selengkapnya, lihat Membuat IAM peran di Panduan IAM Pengguna.