Kinesis - AWS Serverless Application Model
SintaxisPropiedadesEjemplos

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Kinesis

El objeto que describe un tipo de fuente de evento Kinesis. Para obtener más información, consulte Uso AWS Lambda con Amazon Kinesis en la Guía para AWS Lambda desarrolladores.

AWS SAM genera un AWS::Lambda::EventSourceMappingrecurso cuando se establece este tipo de evento.

Sintaxis

Para declarar esta entidad en tu plantilla AWS Serverless Application Model (AWS SAM), usa la siguiente sintaxis.

Propiedades

BatchSize

El número máximo de elementos que se recuperan en un único lote.

Tipo: entero

Obligatorio: no

Valor predeterminado: 100

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la BatchSize propiedad de un AWS::Lambda::EventSourceMapping recurso.

Mínimo: 1

Máximo: 10000

BisectBatchOnFunctionError

Si la función devuelve un error, divida el lote en dos y vuelva a intentarlo.

Tipo: Booleano

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la BisectBatchOnFunctionError propiedad de un AWS::Lambda::EventSourceMapping recurso.

DestinationConfig

Una cola de Amazon Simple Queue Service (AmazonSQS) o un destino de tema de Amazon Simple Notification Service SNS (Amazon) para los registros descartados.

Tipo: DestinationConfig

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se transfiere directamente a la DestinationConfig propiedad de un AWS::Lambda::EventSourceMapping recurso.

Enabled

Deshabilita el mapeo de origen de eventos para pausar el sondeo y la invocación.

Tipo: Booleano

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la Enabled propiedad de un AWS::Lambda::EventSourceMapping recurso.

FilterCriteria

Un objeto que define los criterios que determinan si Lambda debe procesar un evento o no. Para obtener más información, consulta Filtrado de eventos de AWS Lambda en la Guía para desarrolladores de AWS Lambda .

Tipo: FilterCriteria

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la FilterCriteria propiedad de un AWS::Lambda::EventSourceMapping recurso.

FunctionResponseTypes

Una lista de enumeraciones de tipos de respuesta actuales aplicadas a la asignación de origen de eventos. Para obtener más información, consulta Informes de errores de artículos en lotes en la Guía para desarrolladores de AWS Lambda .

Valores válidos: ReportBatchItemFailures

Tipo: lista

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la FunctionResponseTypes propiedad de un AWS::Lambda::EventSourceMapping recurso.

KmsKeyArn

El nombre del recurso de Amazon (ARN) de la clave para cifrar la información relacionada con este evento.

Tipo: cadena

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se transfiere directamente a la KmsKeyArn propiedad de un AWS::Lambda::EventSourceMapping recurso.

MaximumBatchingWindowInSeconds

La cantidad de tiempo máxima para recopilar registros antes de invocar la función, en segundos.

Tipo: Entero

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la MaximumBatchingWindowInSeconds propiedad de un AWS::Lambda::EventSourceMapping recurso.

MaximumRecordAgeInSeconds

La antigüedad máxima de un registro que Lambda envía a una función para su procesamiento.

Tipo: entero

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la MaximumRecordAgeInSeconds propiedad de un AWS::Lambda::EventSourceMapping recurso.

MaximumRetryAttempts

El número máximo de veces que se debe volver a intentar cuando la función devuelve un error.

Tipo: entero

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la MaximumRetryAttempts propiedad de un AWS::Lambda::EventSourceMapping recurso.

MetricsConfig

Una configuración opcional para obtener métricas mejoradas para las asignaciones de fuentes de eventos que capturan cada etapa del procesamiento. Para ver un ejemplo, consulta MetricsConfig evento.

Tipo: MetricsConfig

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se transfiere directamente a la MetricsConfig propiedad de un recurso. AWS::Lambda::EventSourceMapping

ParallelizationFactor

El número de lotes de cada partición que se procesarán simultáneamente.

Tipo: entero

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la ParallelizationFactor propiedad de un AWS::Lambda::EventSourceMapping recurso.

StartingPosition

La posición en el flujo donde comienza la lectura.

  • AT_TIMESTAMP: especifique el tiempo a partir del cual comenzar la lectura de registros.

  • LATEST: registros nuevos de solo lectura.

  • TRIM_HORIZON: procese todos los registros disponibles.

Valores válidos: AT_TIMESTAMP | LATEST | TRIM_HORIZON

Tipo: cadena

Obligatorio: sí

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la StartingPosition propiedad de un AWS::Lambda::EventSourceMapping recurso.

StartingPositionTimestamp

El tiempo a partir del cual comenzar la lectura, en segundos de tiempo Unix. Defina StartingPositionTimestamp cuando StartingPosition se especifica como AT_TIMESTAMP.

Tipo: Doble

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la StartingPositionTimestamp propiedad de un AWS::Lambda::EventSourceMapping recurso.

Stream

El nombre del recurso de Amazon (ARN) de la transmisión de datos o de un consumidor de la transmisión.

Tipo: cadena

Obligatorio: sí

AWS CloudFormation compatibilidad: esta propiedad se transfiere directamente a la EventSourceArn propiedad de un AWS::Lambda::EventSourceMapping recurso.

TumblingWindowInSeconds

La duración, en segundos, de una ventana de procesamiento. El intervalo válido es de 1 a 900 (15 minutos).

Para más información, consulta Ventanas móviles en la Guía para desarrolladores de AWS Lambda .

Tipo: entero

Obligatorio: no

AWS CloudFormation compatibilidad: esta propiedad se pasa directamente a la TumblingWindowInSeconds propiedad de un AWS::Lambda::EventSourceMapping recurso.

Ejemplos

MetricsConfig evento

El siguiente es un ejemplo de un recurso que usa la MetricsConfig propiedad para capturar cada etapa del procesamiento para sus mapeos de fuentes de eventos.

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

Origen de eventos de Kinesis

A continuación, se muestra un ejemplo de origen de evento de 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"]}'