OCI Streaming Services와 ThingsBoard 통합

소개

ThingsBoard는 데이터 수집, 처리, 시각화 및 장치 관리를 위한 오픈 소스 IoT 플랫폼입니다. 이 사용지침서에서는 ThingsBoard를 OCI(Oracle Cloud Infrastructure) 스트리밍 서비스와 통합하기 위해 따라야 할 단계를 보여줍니다. 이렇게 하면 데이터를 데이터베이스에 저장하고, 분석을 수행하고, 함수를 사용하여 이 정보를 수정하고 처리할 수 있습니다.

목표

OCI에서 필요한 정보를 수집합니다.
ThingsBoard 규칙 체인에서 Kafka 노드를 구성합니다.

필요 조건

OCI Streaming, Kafka에 대한 기본 지식
ThingsBoard 규칙 체인에 대한 이해
스트리밍 리소스를 생성하고 액세스할 수 있는 사용자 권한입니다.
ThingsBoard가 시스템에 설치됩니다. Community Edition 설치 단계는 여기에서 확인할 수 있습니다.

작업 1: Kafka 서버와의 통합에 필요한 OCI 조정 매개변수 수집

OCI 스트림이 아직 생성되지 않은 경우 이 단계에 따라 콘솔에서 새 스트림을 생성할 수 있습니다.
기존 스트림의 경우 다음 정보에 유의하십시오.
- 탐색 메뉴를 열고 분석 및 AI를 누릅니다.
- 메시징에서 스트리밍을 누릅니다.
- 스트림 탭에서 기존 스트림을 열고 스트림 이름을 기록합니다(예: thingsboard_stream).
- 스트림 풀 링크를 누릅니다(예: thingsboard_stream_pool).
- 왼쪽 메뉴에서 Kafka Connection Settings로 이동하고 다음 정보를 복사합니다.
  - 부트스트랩 서버: 예: cell-1.streaming.eu-frankfurt-1.oci.oraclecloud.com:9092
  - SASL 접속 문자열: 예: *org.apache.kafka.common.security.plain.PlainLoginModule required username="/oracleidentitycloudservice//" password="AUTH_TOKEN";*
  - 보안 프로토콜: SASL_SSL
  - 보안 방식: PLAIN
- 화면 오른쪽 상단 모서리에서 프로파일 아이콘을 누릅니다. User Profile에서 Auth Token을 누르고 토큰을 생성하고 AUTH_TOKEN 값을 복사합니다(예: xmo?(cv<abcd....). 기존 토큰을 사용할 수도 있습니다.

작업 2: Kafka 규칙 노드 구성

Kafka 규칙 체인

작업 패널에서 Kafka 규칙 노드를 끌어옵니다. 작업 1에 설명된 정보를 사용하여 Kafka 규칙을 구성합니다.
- Name: 예 - ThingsBoard2OCIStream
- 항목 패턴: "StreamName", 예 - thingsdemo-s0
- 부트스트랩 서버: "부트스트랩 서버", 예 - cell-1.streaming.eu-frankfurt-1.oci.oraclecloud.com:9092
- 기타 속성: 추가를 누르고 다음 키 쌍을 추가합니다.
  - security.protocol: "보안 프로토콜" SASL_SSL
  - sasl.mechanism: "보안 방식" PLAIN
  - ssl.endpoint.identification.algorithm: https
  - sasl.jaas.config: <SASL 접속 문자열:>(예: - *org.apache.kafka.common.security.plain.PlainLoginModule required username="//" password="AUTH_TOKEN";*)(AUTH_TOKEN를 작업 1에서 복사된 값으로 바꾸기)

참고:

sasl.jaas.config 문자열이 작동하지 않을 경우 테넌시에 Oracle Identity Cloud Service에 문제가 있을 수 있으므로 로컬 사용자도 마찬가지입니다.

선택 사항: 디버그 모드에서 문제 해결을 확인할 수도 있습니다.

필요한 값을 업데이트한 후 체크마크 버튼을 눌러 구성을 저장합니다.

작업 3: 규칙 체인 구성

규칙 체인 구성

저장된 시계열을 OCI 스트림으로 전달할 수 있도록 저장 시계열과 kafka 블록 간에 "링크를 끌어옵니다."
링크 레이블에 대해 Success를 입력합니다.
구성을 저장하려면 [선택 표시] 단추를 누르십시오.
OCI 콘솔에 로그인하고 스트림에서 데이터를 수신하고 있는지 확인하십시오. 메시지 로드를 누릅니다.

OCI Streaming에서 정보를 받은 후에는 OCI 서비스 커넥터 서비스를 사용하여 OCI 스토리지, OCI 함수 등의 다른 서비스로 전송할 수 있습니다.

수락

Adina Nicolescu(수석 클라우드 엔지니어), Guido Alejandro Ferreyra(주요 클라우드 설계자)

추가 학습 자원

docs.oracle.com/learn에서 다른 실습을 탐색하거나 Oracle Learning YouTube 채널에서 더 많은 무료 학습 콘텐츠에 액세스할 수 있습니다. 또한 education.oracle.com/learning-explorer을 방문하여 Oracle Learning Explorer가 됩니다.

제품 설명서는 Oracle Help Center를 참조하십시오.

제목 및 저작권 정보

Integrate ThingsBoard with OCI Streaming Services

F79939-01

April 2023