다음을 통해 공유

Azure IoT 데이터 프로세서 미리 보기 파이프라인에서 HTTP 엔드포인트 원본 단계 구성

  • 아티클

Important

Azure IoT 작업 미리 보기 - Azure Arc에서 지원되는 Azure IoT 작업은 현재 미리 보기로 제공됩니다. 프로덕션 환경에서는 이 미리 보기 소프트웨어를 사용하면 안 됩니다.

베타, 미리 보기로 제공되거나 아직 일반 공급으로 릴리스되지 않은 Azure 기능에 적용되는 약관은 Microsoft Azure 미리 보기에 대한 추가 사용 약관을 참조하세요.

원본 단계는 Azure IoT 데이터 프로세서 미리 보기 파이프라인의 첫 번째 필수 단계입니다. 원본 단계에서는 데이터 처리 파이프라인으로 데이터를 가져오고 추가 처리를 위해 준비합니다. HTTP 엔드포인트 원본 단계를 사용하면 사용자가 정의한 간격으로 HTTP 엔드포인트에서 데이터를 읽을 수 있습니다. 단계에는 선택적 요청 본문이 있으며 엔드포인트에서 응답을 받습니다.

원본 단계에서는 다음을 정의합니다.

  • HTTP 엔드포인트에 대한 연결 세부 정보입니다.
  • HTTP 엔드포인트를 호출하는 간격입니다. 단계는 간격 타이머를 다시 설정하기 전에 응답을 기다립니다.
  • 특정 데이터 처리 요구 사항에 따른 분할 구성입니다.

필수 조건

  • 데이터 프로세서의 작동 인스턴스가 배포됩니다.
  • 필요한 모든 원시 데이터를 사용할 수 있는 HTTP 엔드포인트가 작동하고 연결 가능합니다.

HTTP 엔드포인트 원본 구성

HTTP 엔드포인트 원본을 구성하려면 다음 안내를 따릅니다.

  • HTTP 엔드포인트의 세부 정보를 제공합니다. 이 구성에는 사용할 메서드, URL 및 요청 페이로드가 포함됩니다.
  • 인증 방법을 지정합니다. 현재는 사용자 이름/암호 기반 또는 헤더 기반 인증으로 제한됩니다.

다음 표에는 HTTP 엔드포인트 원본 구성 매개 변수가 설명되어 있습니다.

필드 형식 설명 필수 항목 기본값 예시
이름 문자열 원본 스테이지의 고객이 볼 수 있는 이름입니다. Required 해당 없음 erp-endpoint
설명 문자열 원본 스테이지에 대한 고객이 볼 수 있는 설명입니다. 선택 사항 해당 없음 Enterprise application data
메서드 열거형 요청에 사용할 HTTP 메서드입니다. GET 또는 POST 중 하나입니다. 선택 사항 GET GET
URL 문자열 요청에 사용할 URL입니다. http 및 https가 모두 지원됩니다. Required 해당 없음 https://contoso.com/some/url/path
인증 Authentication type HTTP 요청에 대한 인증 방법입니다. None, Username/Password 또는 Header 중 하나입니다. 선택 사항 NA Username/Password
사용자 이름/암호 > 사용자 이름 문자열 사용자 이름/암호 인증의 사용자 이름입니다. 예 해당 없음 myuser
사용자 이름/암호 > 비밀 Azure Key Vault에 저장된 암호에 대한 참조입니다. 예 예 AKV_USERNAME_PASSWORD
헤더 > 키 문자열 헤더 기반 인증을 위한 키 이름입니다. 예 해당 없음 Authorization
헤더 > 값 문자열 헤더 기반 인증을 위한 Azure Key Vault의 자격 증명 이름입니다. 예 해당 없음 AKV_PASSWORD
데이터 형식 형식 들어오는 데이터의 데이터 형식 Required 해당 없음 {"type": "json"}
API 요청 > 요청 본문 문자열 HTTP 요청과 함께 보낼 정적 요청 본문입니다. 선택 사항 해당 없음 {"foo": "bar"}
API 요청 > 헤더 키/값 쌍 HTTP 요청과 함께 보낼 정적 요청 헤더입니다. 선택 사항 해당 없음 [{"key": {"type":"static", "value": "asset"}, "value": {"type": "static", "value": "asset-id-0"}} ]
요청 간격 기간 다음 API 호출 전 대기 시간을 문자열로 표현한 것입니다. Required 10s 24h
분할 분할 원본 스테이지의 분할 구성입니다. Required 해당 없음 파티션 나누기를 참조하세요.

비밀에 대한 자세한 내용은 Azure IoT Operations 미리 보기 배포에 대한 비밀 관리를 참조하세요.

데이터 형식 선택

데이터 프로세서 파이프라인에서 원본 스테이지의 형식 필드는 들어오는 데이터를 역직렬화하는 방법을 지정합니다. 기본적으로 데이터 프로세서 파이프라인은 들어오는 데이터를 변환하지 않음을 의미하는 raw 형식을 사용합니다. 파이프라인의 Filter 또는 Enrich 스테이지와 많은 데이터 프로세서 기능을 사용하려면 입력 스테이지에서 데이터를 역직렬화해야 합니다. 전체 데이터 프로세서 기능을 사용하기 위해 JSON, jsonStream, MessagePack, CBOR, CSV 또는 Protobuf 형식에서 들어오는 데이터를 데이터 프로세서에서 읽을 수 있는 메시지로 역직렬화하도록 선택할 수 있습니다.

다음 표에서는 다양한 역직렬화 구성 옵션에 대해 설명합니다.

필드 설명 필수 항목 기본값 값
데이터 형식 데이터 형식의 유형입니다. 예 Raw Raw JSON jsonStream MessagePack CBOR CSV Protobuf

Data Format 필드는 필수이며 해당 값은 다른 필수 필드를 결정합니다.

CSV 메시지를 역직렬화하려면 다음 필드도 지정해야 합니다.

필드 설명 필수 값 예제
헤더 CSV 데이터에 헤더 줄이 포함되는지 여부입니다. 예 Yes No No
이름 CSV 열 이름입니다. 예 - temp, asset
Path 열 정보가 추가되는 메시지의 jq 경로 입니다. 아니요 - 기본 jq 경로는 열 이름입니다.
데이터 형식 열에 있는 데이터의 데이터 형식 및 데이터 프로세서 파이프라인 내에서 데이터 형식이 표시되는 방식입니다. 아니요 String, Float, Integer, BooleanBytes 기본값: String

Protobuf 메시지를 역직렬화하려면 다음 필드도 지정해야 합니다.

필드 설명 필수 값 예제
설명자 protobuf 정의에 대한 base64로 인코딩된 설명자입니다. 예 - Zhf...
메시지 데이터 형식을 지정하는 데 사용되는 메시지 형식의 이름입니다. 예 - pipeline
Package(패키지) 형식이 정의된 설명자에 있는 패키지의 이름입니다. 예 - schedulerv1

참고 항목

데이터 프로세서는 각 .proto 파일에서 하나의 메시지 형식만 지원합니다.

분할 구성

파이프라인에서 분할하면 들어오는 데이터를 별도의 파티션으로 나눕니다. 분할을 사용하면 파이프라인에서 데이터 병렬 처리를 통해 처리량을 개선하고 대기 시간을 줄일 수 있습니다. 분할 전략은 파이프라인의 다른 스테이지에서 데이터가 처리되는 방식에 영향을 미칩니다. 예를 들어 마지막으로 알려진 값 스테이지 및 집계 스테이지는 각 논리 파티션에서 작동합니다.

데이터를 분할하려면 분할 전략과 사용할 파티션 수를 지정합니다.

필드 설명 필수 항목 기본값 예시
파티션 유형 사용할 분할 유형: 파티션 ID 또는 파티션 Key Required ID ID
파티션 식 들어오는 메시지에서 파티션 ID 또는 파티션 Key를 계산하는 데 사용할 jq 식 입니다. Required 0 .payload.header
파티션 수 데이터 프로세서 파이프라인의 파티션 수입니다. Required 1 1

원본 단계는 분할 식을 들어오는 메시지에 적용하여 파티션 ID 또는 Key를 계산합니다.

데이터 프로세서는 들어오는 메시지에 추가 메타데이터를 추가합니다. 들어오는 메시지에서 실행되는 분할 식을 올바르게 지정하는 방법을 이해하려면 데이터 프로세서 메시지 구조 개요를 참조하세요. 기본적으로 파티션 식은 들어오는 모든 데이터를 단일 파티션으로 보내기 위해 ID인 파티션 형식을 가진 0으로 설정됩니다.

권장 사항 및 자세한 내용은 파티션 나누기란?을 참조하세요.

관련 콘텐츠