Cargar datos de streaming desde Amazon Kinesis Data Streams - Amazon OpenSearch Service
Requisitos previos

Cargar datos de streaming desde Amazon Kinesis Data Streams

Puede cargar datos de streaming desde Kinesis Data Streams en OpenSearch Service. Cuando llegan datos nuevos al flujo de datos, activan una notificación de eventos en Lambda que, a su vez, ejecuta el código personalizado para realizar la indexación. En esta sección, se incluye un código de muestra simple de Python.

Requisitos previos

Antes de continuar, debe contar con los siguientes recursos.

Requisito previo Descripción
Amazon Kinesis Data Streams Fuente de eventos de la función Lambda Para más información, consulte Kinesis Data Streams.
Dominio de OpenSearch Service Es el destino de los datos después de que la función Lambda los procesa. Para más información, consulte Creación de dominios de OpenSearch Service.
Rol de IAM

Este rol debe tener permisos básicos para OpenSearch Service, Kinesis y Lambda, como los siguientes:

JSON
{
  "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": "*"
    }
  ]
}

El rol debe tener la siguiente relación de confianza:

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

Para más información, consulte Creación de roles de IAM en la Guía del usuario de IAM.