从 Amazon Kinesis Data Streams 加载流数据 - Amazon OpenSearch Service
先决条件
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

从 Amazon Kinesis Data Streams 加载流数据

您可以从 Kinesis Data Streams 将流数据加载到 OpenSearch Service。到达此数据流的新数据将向 Lambda 触发事件通知，这将运行自定义代码以执行索引编制。此节包括一些简单的 Python 示例代码。

先决条件

继续操作之前，必须具有以下资源。

先决条件 描述
Amazon Kinesis Data Stream Lambda 函数的事件源。要了解更多信息，请参阅 Kinesis Data Streams。
OpenSearch Service 域 Lambda 函数处理数据之后数据的目的地。有关更多信息，请参阅 创建 OpenSearch Service 域
IAM 角色

此角色必须具有基本的 OpenSearch Service、Kinesis 和 Lambda 权限，如以下内容：

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

角色必须拥有以下信任关系：

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

要了解更多信息，请参阅 IAM 用户手册中的创建 IAM 角色。