Kinesis - AWS Serverless Application Model

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 unKinesistipo de origen de evento. Para obtener más información, consulteUso deAWS Lambdacon Amazon Kinesisen laAWS LambdaGuía para desarrolladores.

AWS SAMgenera unAWS::Lambda::EventSourceMappingrecurso cuando se establece este tipo de evento.

Sintaxis

Para declarar esta entidad en suAWS Serverless Application Model(AWS SAM), utilice la siguiente sintaxis.

Properties

BatchSize

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

Type: Entero

Obligatorio: No

Valor predeterminado: 100

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alBatchSizepropiedad de unAWS::Lambda::EventSourceMappingrecurso.

Minimum: 1

Maximum: 10000

BisectBatchOnFunctionError

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

Type: Booleano

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alBisectBatchOnFunctionErrorpropiedad de unAWS::Lambda::EventSourceMappingrecurso.

DestinationConfig

Una cola de Amazon Simple Queue Service (Amazon SQS) o un destino de tema de Amazon Simple Notification Service (Amazon SNS) para registros desechados.

Type: DestinationConfig

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alDestinationConfigpropiedad de unAWS::Lambda::EventSourceMappingrecurso.

Enabled

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

Type: Booleano

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alEnabledpropiedad de unAWS::Lambda::EventSourceMappingrecurso.

FilterCriteria

Un objeto que define los criterios para determinar si Lambda debe procesar un evento. Para obtener más información, consulteAWS LambdaFiltrado de eventosen laAWS LambdaGuía para desarrolladores.

Type: FilterCriteria

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alFilterCriteriapropiedad de unAWS::Lambda::EventSourceMappingrecurso.

FunctionResponseTypes

Una lista de los tipos de respuesta aplicados actualmente a la asignación de origen de eventos. Para obtener más información, consulteInformes de fallos de artículos de loteen laAWS LambdaGuía para desarrolladores.

Valores válidos: ReportBatchItemFailures

Type: Lista

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alFunctionResponseTypespropiedad de unAWS::Lambda::EventSourceMappingrecurso.

MaximumBatchingWindowInSeconds

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

Type: Entero

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alMaximumBatchingWindowInSecondspropiedad de unAWS::Lambda::EventSourceMappingrecurso.

MaximumRecordAgeInSeconds

Antigüedad máxima de un registro que Lambda envía a una función para que lo procese.

Type: Entero

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alMaximumRecordAgeInSecondspropiedad de unAWS::Lambda::EventSourceMappingrecurso.

MaximumRetryAttempts

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

Type: Entero

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alMaximumRetryAttemptspropiedad de unAWS::Lambda::EventSourceMappingrecurso.

ParallelizationFactor

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

Type: Entero

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alParallelizationFactorpropiedad de unAWS::Lambda::EventSourceMappingrecurso.

StartingPosition

Posición del flujo donde comienza la lectura.

Valores válidos: TRIM_HORIZON o LATEST

Type: Cadena

Obligatorio: Sí

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alStartingPositionpropiedad de unAWS::Lambda::EventSourceMappingrecurso.

Stream

El nombre de recurso de Amazon (ARN) del flujo de datos o un consumidor de flujos.

Type: Cadena

Obligatorio: Sí

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alEventSourceArnpropiedad de unAWS::Lambda::EventSourceMappingrecurso.

TumblingWindowInSeconds

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

Para obtener más información, consulteVentanas de saltos de tamaño constanteen laAWS LambdaGuía para desarrolladores.

Type: Entero

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alTumblingWindowInSecondspropiedad de unAWS::Lambda::EventSourceMappingrecurso.

Ejemplos

Origen de eventos de Kinesis

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