Amazon Kinesis Data Streams에서 스트리밍 데이터 로드 - Amazon OpenSearch 서비스
사전 조건

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

Amazon Kinesis Data Streams에서 스트리밍 데이터 로드

Kinesis Data Streams에서 OpenSearch Service로 스트리밍 데이터를 로드할 수 있습니다. 데이터 스트림에 도착한 새 데이터는 Lambda로 이벤트 알림을 트리거한 다음 사용자 지정 코드를 실행해 인덱싱합니다. 이 단원에는 단순한 Python 샘플 코드가 있습니다.

사전 조건

계속하려면 먼저 다음 리소스를 확보해야 합니다.

전제 조건 설명
Amazon Kinesis Data Stream Lambda 함수의 이벤트 소스. 자세한 내용은 Kinesis Data Streams를 참조하세요.
OpenSearch Service 도메인 Lambda 함수로 처리한 후의 데이터 대상 주소입니다. 자세한 내용은 OpenSearch 서비스 도메인 생성 섹션을 참조하세요.
IAM 역할

이 역할에는 다음과 같은 기본 OpenSearch Service, Kinesis 및 Lambda 권한이 있어야 합니다.

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

역할은 다음과 같은 신뢰 관계를 맺고 있어야 합니다.

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

자세한 내용은 IAM 사용 설명서의 IAM 역할 생성을 참조하세요.