Kinesis - AWS Serverless Application Model
SintaksPropertiContoh

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

Kinesis

Objek yang menggambarkan tipe sumber peristiwa Kinesis. Untuk informasi selengkapnya, lihat Menggunakan AWS Lambda dengan Amazon Kinesis di Panduan AWS Lambda Pengembang.

AWS SAM menghasilkan sebuah AWS::Lambda::EventSourceMappingsumber daya saat jenis acara ini disetel.

Sintaks

Untuk mendeklarasikan entitas ini dalam template AWS Serverless Application Model (AWS SAM) Anda, gunakan sintaks berikut.

Properti

BatchSize

Jumlah maksimum item yang akan diambil dalam satu batch.

Tipe: Integer

Wajib: Tidak

Default: 100

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke BatchSize properti AWS::Lambda::EventSourceMapping sumber daya.

Minimal: 1

Maksimum: 10000

BisectBatchOnFunctionError

Jika fungsi mengembalikan kesalahan, bagi batch menjadi dua dan coba lagi.

Tipe: Boolean

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke BisectBatchOnFunctionError properti AWS::Lambda::EventSourceMapping sumber daya.

DestinationConfig

Antrean Amazon Simple Queue Service (Amazon SQS) atau tujuan topik Amazon Simple Notification Service (Amazon SNS) untuk catatan yang dibuang.

Jenis: DestinationConfig

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke DestinationConfig properti AWS::Lambda::EventSourceMapping sumber daya.

Enabled

Menonaktifkan pemetaan sumber peristiwa untuk menjeda polling dan pemanggilan.

Tipe: Boolean

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke Enabled properti AWS::Lambda::EventSourceMapping sumber daya.

FilterCriteria

Objek yang mendefinisikan kriteria untuk menentukan apakah Lambda harus memproses suatu peristiwa. Untuk informasi selengkapnya, lihat pemfilteran AWS Lambda acara di Panduan AWS Lambda Pengembang.

Jenis: FilterCriteria

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke FilterCriteria properti AWS::Lambda::EventSourceMapping sumber daya.

FunctionResponseTypes

Daftar tipe jawaban saat ini yang diterapkan ke pemetaan sumber peristiwa. Untuk informasi selengkapnya, lihat Melaporkan kegagalan item batch di Panduan Developer AWS Lambda .

Nilai yang valid: ReportBatchItemFailures

Tipe: Daftar

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke FunctionResponseTypes properti AWS::Lambda::EventSourceMapping sumber daya.

KmsKeyArn

Nama Sumber Daya Amazon (ARN) dari kunci untuk mengenkripsi informasi yang terkait dengan acara ini.

Tipe: String

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke KmsKeyArn properti AWS::Lambda::EventSourceMapping sumber daya.

MaximumBatchingWindowInSeconds

Jumlah waktu maksimum untuk mengumpulkan rekaman sebelum memanggil fungsi, dalam hitungan detik.

Tipe: Integer

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke MaximumBatchingWindowInSeconds properti AWS::Lambda::EventSourceMapping sumber daya.

MaximumRecordAgeInSeconds

Periode permintaan maksimum yang dikirimkan Lambda ke fungsi untuk diproses.

Tipe: Integer

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke MaximumRecordAgeInSeconds properti AWS::Lambda::EventSourceMapping sumber daya.

MaximumRetryAttempts

Jumlah waktu maksimum untuk mencoba kembali saat fungsi mengembalikan kesalahan.

Tipe: Integer

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke MaximumRetryAttempts properti AWS::Lambda::EventSourceMapping sumber daya.

MetricsConfig

Konfigurasi keikutsertaan untuk mendapatkan metrik yang disempurnakan untuk pemetaan sumber peristiwa yang menangkap setiap tahap pemrosesan. Sebagai contoh, lihat MetricsConfig acara.

Jenis: MetricsConfig

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke MetricsConfig properti AWS::Lambda::EventSourceMapping sumber daya.

ParallelizationFactor

Jumlah batch yang akan diproses dari tiap serpihan secara bersamaan.

Tipe: Integer

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke ParallelizationFactor properti AWS::Lambda::EventSourceMapping sumber daya.

StartingPosition

Posisi dalam pengaliran tempat untuk mulai membaca.

  • AT_TIMESTAMP— Tentukan waktu untuk mulai membaca catatan.

  • LATEST— Baca hanya catatan baru.

  • TRIM_HORIZON— Memproses semua catatan yang tersedia.

Nilai yang valid: AT_TIMESTAMP | LATEST | TRIM_HORIZON

Tipe: String

Wajib: Ya

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke StartingPosition properti AWS::Lambda::EventSourceMapping sumber daya.

StartingPositionTimestamp

Waktu untuk mulai membaca, dalam detik waktu Unix. Tentukan StartingPositionTimestamp kapan StartingPosition ditentukan sebagaiAT_TIMESTAMP.

Tipe: Ganda

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke StartingPositionTimestamp properti AWS::Lambda::EventSourceMapping sumber daya.

Stream

Amazon Resource Name (ARN) dari aliran data atau konsumen pengaliran.

Tipe: String

Wajib: Ya

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke EventSourceArn properti AWS::Lambda::EventSourceMapping sumber daya.

TumblingWindowInSeconds

Durasi dalam detik dari periode pemrosesan. Kisaran yang valid adalah 1 sampai 900 (15 menit).

Untuk informasi selengkapnya, lihat Periode Jatuh di Panduan Developer AWS Lambda .

Tipe: Integer

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke TumblingWindowInSeconds properti AWS::Lambda::EventSourceMapping sumber daya.

Contoh

MetricsConfig acara

Berikut ini adalah contoh sumber daya yang menggunakan MetricsConfig properti untuk menangkap setiap tahap pemrosesan untuk pemetaan sumber peristiwa mereka.

Resources:
  FilteredEventsFunction:
    Type: AWS::Serverless::Function
    Properties:
      CodeUri: s3://sam-demo-bucket/metricsConfig.zip
      Handler: index.handler
      Runtime: nodejs16.x
      Events:
        KinesisStream:
          Type: Kinesis
          Properties:
            Stream: !GetAtt KinesisStream.Arn
            StartingPosition: LATEST
            MetricsConfig:
              Metrics:
              - EventCount

Sumber peristiwa Kinesis

Berikut ini adalah contoh sumber peristiwa Kinesis.

YAML

Events:
  KinesisEvent:
    Type: Kinesis
    Properties:
      Stream: arn:aws:kinesis:us-east-1:123456789012:stream/my-stream
      StartingPosition: TRIM_HORIZON
      BatchSize: 10
      Enabled: false
      FilterCriteria: 
        Filters: 
          - Pattern: '{"key": ["val1", "val2"]}'