모든 컨트롤러(알파벳순)¶
이 항목에서는 알파벳 순으로 모든 openflow 컨트롤러 목록을 제공합니다. 이 목록은 다음을 포함합니다.
컨트롤러 유형(Snowflake 여부)
각 컨트롤러의 이름
각 컨트롤러에 대한 요약
A¶
컨트롤러 |
설명 |
|
---|---|---|
ADLS 프로세서에 대한 자격 증명을 정의합니다. |
||
다른 ADLSCredentialsService 를 동적으로 선택하는 데 사용할 수 있는 ADLSCredentialsService 공급자를 제공합니다. |
||
AWS Glue Schema Registry와 상호 작용하는 Schema Registry를 제공하여 Glue Schema Registry에 저장된 스키마를 NiFi 에서 사용할 수 있도록 합니다. |
||
공급자 또는 컨슈머 작업을 위해 AWS MSK Kafka Brokers에 대한 연결을 제공하고 관리합니다. |
||
Snowflake |
공급자 또는 컨슈머 작업을 위해 AWS MSK Kafka Brokers에 대한 연결을 제공하고 관리합니다. |
|
Apicurio Schema Registry와 상호 작용하는 Schema Registry를 제공하여 Apicurio Schema Registry에 저장된 스키마를 NiFi 에서 사용할 수 있도록 합니다. |
||
Avro 데이터를 구문 분석하고 각 Avro 레코드를 별도의 레코드 오브젝트로 반환합니다. |
||
RecordSet 의 내용을 이진 Avro 형식으로 작성합니다. |
||
스키마 등록 및 액세스를 위한 서비스를 제공합니다. |
||
Amazon Web Services 프로세서에 대한 자격 증명을 정의합니다. |
||
다른 구성 요소에 대한 Azure Blob Storage 파일 리소스를 제공합니다. |
||
Cosmos DB(Core SQL API)에 대한 연결을 구성하고 다른 Cosmos DB 관련 구성 요소에 해당 연결에 대한 액세스를 제공하는 컨트롤러 서비스를 제공합니다. |
||
다른 구성 요소에 대한 Azure Data Lake Storage(ADLS) 파일 리소스를 제공합니다. |
||
레코드 형식 지정 및 Azure Event Hubs로 보내기 |
||
Azure Storage 클라이언트 라이브러리 v12를 사용하여 Azure Storage 프로세서에 대한 자격 증명을 제공합니다. |
||
다른 AzureStorageCredentialsService_v12를 동적으로 선택하는 데 사용할 수 있는 AzureStorageCredentialsService_v12를 제공합니다. |
C¶
컨트롤러 |
설명 |
|
---|---|---|
CEF (공통 이벤트 형식) 이벤트를 구문 분석하여 각 행을 레코드로 반환합니다. |
||
바이트 마커와 4바이트로 표현되는 정수로 구성된 헤더로 Confluent 인코딩에 따라 스키마 식별자를 읽습니다. |
||
바이트 마커와 4바이트로 표현되는 정수로 구성된 헤더로 Confluent 인코딩에 따라 스키마 식별자를 씁니다. |
||
Confluent Schema Registry에 저장된 스키마를 NiFi 에서 사용할 수 있도록 Confluent Schema Registry와 상호 작용하는 Schema Registry를 제공합니다. |
||
CSV 형식의 데이터를 구문 분석하여 CSV 파일의 각 행을 별도의 레코드로 반환합니다. |
||
재로드 가능한 CSV 파일 기반 조회 서비스입니다. |
||
RecordSet 의 내용을 CSV 데이터로 씁니다. |
D¶
컨트롤러 |
설명 |
|
---|---|---|
Snowflake |
사용자가 지정한 SQL 문을 사용하여 데이터베이스를 보강할 수 있는 조회 서비스입니다. |
|
관계형 데이터베이스 기반 조회 서비스입니다. |
||
구성된 데이터베이스 연결을 사용하여 레코드를 작성하는 서비스를 제공합니다. |
||
데이터베이스 연결 풀링 서비스를 제공합니다. |
||
다른 DBCPService 를 동적으로 선택하는 데 사용할 수 있는 DBCPService 를 제공합니다. |
||
Box API 호출을 사용할 수 있는 Box 클라이언트 오브젝트를 제공합니다. |
||
키에 연결된 값을 검색할 분산 맵 캐시 클라이언트를 선택할 수 있습니다. |
E¶
컨트롤러 |
설명 |
|
---|---|---|
Elasticsearch (하위 수준) REST 클라이언트를 사용하여 Elasticsearch 클라이언트에 액세스하기 위한 컨트롤러 서비스입니다. |
||
지정된 문서 ID 와 연결된 Elasticsearch 서버에서 레코드를 조회합니다. |
||
지정된 문서 ID 와 연결된 Elasticsearch 서버에서 문자열 값을 조회합니다. |
||
지정된 형식의 작성기를 사용하여 이메일로 레코드를 전송하는 데 사용할 수 있는 RecordSinkService 공급자를 제공합니다. |
||
임베디드 Hazelcast을 실행하고 이를 통해 캐시 인스턴스를 제공하는 서비스입니다. |
||
Microsoft Excel 문서를 구문 분석하여 각 시트의 각 행을 별도의 레코드로 반환합니다. |
||
NiFi 의 외부에서 실행되는 Hazelcast가 지원하는 캐시 인스턴스를 제공하는 서비스입니다. |
F¶
컨트롤러 |
설명 |
|
---|---|---|
RecordSet 의 내용을 자유 형식 텍스트로 작성합니다. |
G¶
컨트롤러 |
설명 |
|
---|---|---|
Google Cloud Platform 프로세서에 대한 자격 증명을 정의합니다. |
||
다른 구성 요소를 위한 Google Compute Storage(GCS) 파일 리소스를 제공합니다. |
||
로그 파일과 같은 비정형 텍스트 데이터를 읽고 처리할 수 있도록 데이터를 구조화하기 위한 메커니즘을 제공합니다. |
H¶
컨트롤러 |
설명 |
|
---|---|---|
Hazelcast를 백업 캐시로 사용하는 DistributedMapCacheClient 구현입니다. |
||
HikariCP 를 기반으로 데이터베이스 연결 풀링 서비스를 제공합니다. |
||
HTTP post를 사용하여 레코드를 형식화하고 구성된 URL로 전송합니다. |
I¶
컨트롤러 |
설명 |
|
---|---|---|
IP 주소에 대한 여러 유형의 보강 정보를 제공하는 조회 서비스입니다. |
J¶
컨트롤러 |
설명 |
|
---|---|---|
WebSocketClientService 의 구현입니다. |
||
WebSocketServerService 의 구현입니다. |
||
공급업체별 Javascript를 생성하기 위한 일반 서비스를 제공합니다. |
||
Java 네이밍 및 디렉터리 인터페이스(JNDI)를 사용하여 기존 JMS ConnectionFactory 를 조회하는 서비스를 제공합니다. |
||
Box API 호출을 사용할 수 있는 Box 클라이언트 오브젝트를 제공합니다. |
||
JSON 을 구문 분석하여 각 JSON 오브젝트에 대해 사용자 정의된 JSON 경로를 기록하고 평가합니다. |
||
RecordSet 의 결과를 JSON 배열 또는 한 줄당 1개의 JSON 오브젝트로 씁니다. |
||
Snowflake |
JSON 구성을 기반으로 테이블 열 필터를 제공합니다. |
|
JSON 을 개별 레코드 오브젝트로 구문 분석합니다. |
||
OAuth 2를 제공합니다. |
K¶
컨트롤러 |
설명 |
|
---|---|---|
공급자 또는 컨슈머 작업을 위해 Kafka Broker에 대한 연결을 제공하고 관리합니다. |
||
Snowflake |
공급자 또는 컨슈머 작업을 위해 Kafka Broker에 대한 연결을 제공하고 관리합니다. |
L¶
컨트롤러 |
설명 |
|
---|---|---|
애플리케이션 로그(nifi-app)에 레코드를 기록하는 데 사용할 수 있는 RecordSinkService 공급자를 제공합니다. |
M¶
컨트롤러 |
설명 |
|
---|---|---|
MapCacheServer 와 통신하는 기능을 제공합니다. |
||
소켓을 통해 액세스할 수 있는 매핑(키/값) 캐시를 제공합니다. |
||
Snowflake |
클라이언트 인증서와 함께 클라이언트_크레덴셜을 사용하여 Microsoft 그래프 API 에 대한 OAuth2 액세스 토큰을 제공합니다. |
|
Snowflake |
Microsoft 365 서비스와 상호 작용하는 데 사용할 수 있는 Microsoft Graph API 에 대한 인증을 제공합니다. |
|
MongoDB 에 대한 연결을 구성하고 다른 Mongo 관련 구성 요소에 해당 연결에 대한 액세스를 제공하는 컨트롤러 서비스를 제공합니다. |
||
MongoDB 을 기반으로 조회 서비스를 제공합니다. |
P¶
컨트롤러 |
설명 |
|
---|---|---|
Snowflake |
Apache Parquet 형식을 사용하여 Apache Iceberg에 레코드 직렬화를 제공합니다. |
|
SSLContext 공급자는 PEM 개인 키 및 인증서 파일을 사용하여 구성할 수 있습니다. |
||
Snowflake |
Apache Iceberg와 Apache Polaris 카탈로그를 통합하여 REST HTTP 에 대한 액세스를 제공합니다. |
|
재로드 가능한 속성 파일 기반 조회 서비스 |
R¶
컨트롤러 |
설명 |
|
---|---|---|
다른 RecordReaderFactory 를 동적으로 선택하는 데 사용할 수 있는 RecordReaderFactory 를 제공합니다. |
||
다른 RecordSetWriterFactory 를 동적으로 선택하는 데 사용할 수 있는 RecordSetWriterFactory 를 제공합니다. |
||
다른 RecordSinkService 를 동적으로 선택하는 데 사용할 수 있는 RecordSinkService 를 제공합니다. |
||
Redis에 연결을 제공하는 서비스입니다. |
||
Redis를 백업 캐시로 사용하는 DistributedMapCacheClient 구현입니다. |
||
REST 서비스를 사용하여 값을 조회합니다. |
S¶
컨트롤러 |
설명 |
|
---|---|---|
다른 구성 요소에 대한 Amazon Web Services(AWS) S3 파일 리소스를 제공합니다. |
||
Snowflake |
구성된 OAuth2 액세스 토큰 공급자를 사용하여 Salesforce에서 OAuth2 액세스 토큰을 검색하고 해당 토큰을 데이터 클라우드 API 토큰으로 교환합니다. |
|
사용자가 수신 플로우 파일에서 레코드를 보강하기 위해 스크립트화된 LookupService 인스턴스를 제공할 수 있습니다. |
||
사용자가 수신 플로우 파일에서 레코드를 읽기/구문 분석/생성하기 위해 스크립트화된 RecordReaderFactory 인스턴스를 제공할 수 있습니다. |
||
사용자가 발신 플로우 파일에 레코드를 쓰기 위해 스크립트화된 RecordSetWriterFactory 인스턴스를 제공할 수 있습니다. |
||
사용자가 원하는 대상으로 레코드를 전송하기 위해 스크립트화된 RecordSinkService 인스턴스를 제공할 수 있습니다. |
||
SetCacheServer 와 통신하는 기능을 제공합니다. |
||
소켓을 통해 액세스할 수 있는 세트(고유 값 모음) 캐시를 제공합니다. |
||
재로드 가능한 CSV 파일 기반 조회 서비스입니다. |
||
관계형 데이터베이스 기반 조회 서비스입니다. |
||
사용자가 키-값 페어를 사용자 정의 속성으로 추가할 수 있습니다. |
||
Redis를 백업 캐시로 사용하는 DistributedMapCacheClient 구현입니다. |
||
사용자가 수신 플로우 파일에서 레코드를 보강하기 위해 스크립트화된 LookupService 인스턴스를 제공할 수 있습니다. |
||
Slack Post Message API 를 사용하여 구성된 채널에 레코드의 형식을 지정하고 전송합니다. |
||
공유 인증 자격 증명을 사용하여 SMB 세션에 대한 액세스를 제공합니다. |
||
Snowflake |
Snowflake 서비스에 풀링된 데이터베이스 연결을 제공합니다 |
|
Snowflake |
Snowflake를 지원하는 데이터베이스 언어 서비스. |
|
Snowflake |
||
Snowflake |
||
Snowflake |
메시지 API 를 통해 Anthropic의 Claude AI 모델과 통합을 제공하는 컨트롤러 서비스입니다. |
|
Azure 클라이언트에서 사용할 자격 증명을 제공합니다. |
||
Snowflake |
Databricks 클라이언트. |
|
Dropbox 프로세서에 대한 자격 증명을 정의합니다. |
||
다른 구성 요소에 대한 파일 리소스를 제공합니다. |
||
HashiCorp Vault와 상호 작용하기 위한 컨트롤러 서비스입니다. |
||
프로세서 외부에 HTTP 요청 및 응답을 저장하고 검색하는 기능을 제공하여 여러 프로세서가 동일한 HTTP 요청과 상호 작용할 수 있도록 합니다. |
||
Snowflake |
HubSpot HTTP API와 통합할 HubSpot 컨트롤러 서비스입니다. |
|
JSON 스키마 등록 및 액세스를 위한 서비스를 제공합니다. |
||
flowfile 내용 배치 또는 스트림 flowfile 내용을 Azure ADX 클러스터로 보냅니다. |
||
Azure Data Explorer를 위한 Kusto 쿼리 서비스의 표준 구현 |
||
Snowflake |
Milvus 인스턴스에 연결 서비스를 제공합니다 |
|
OAuth 2를 제공합니다. |
||
Snowflake |
Openflow OCR 서비스에 대한 통합을 제공합니다 |
|
Snowflake |
OpenAI 의 Chat Completion API 와 통합을 제공하는 컨트롤러 서비스입니다. |
|
PGP 개인 키 서비스는 파일 또는 속성에서 로딩된 개인 키를 제공합니다 |
||
파일에서 로딩된 공개 키를 제공하는 PGP 공개 키 서비스 공급자 |
||
개인 키 서비스는 구성된 소스에서 로딩된 개인 키에 대한 액세스를 제공합니다 |
||
프록시 서버를 사용하기 위한 다양한 NiFi 구성 요소에 대한 구성 세트를 제공합니다. |
||
SSLContextService 의 제한적 구현. |
||
S3 Put 및 S3 Fetch 작업에 구성 가능한 암호화를 추가합니다. |
||
Snowflake |
Salesforce APIs 에 연결 서비스 제공 |
|
Snowflake |
Salesforce Data Cloud APIs 에 연결 서비스 제공 |
|
SSLContextService 의 표준 구현. |
||
Snowflake |
테이블 상태를 제공하고 관리하는 컨트롤러 서비스입니다. |
|
Snowflake |
Vectara HTTP API를 통합하기 위한 Vectara 컨트롤러 서비스. |
|
표준 HTTP 연결 속성 구성을 지원하는 웹 클라이언트 서비스 공급자 |
||
Snowflake |
기본 제공 NiFi 상태 관리를 사용하여 테이블 스키마의 해시를 저장합니다. |
|
로그 파일과 같은 RFC 5424 호환 Syslog 데이터를 읽고 처리할 수 있도록 데이터를 구조화하기 위한 메커니즘을 제공합니다. |
||
RFC5424 및 RFC3164 에 따라 Syslog 메시지의 내용을 구문 분석하려고 시도합니다. |
U¶
컨트롤러 |
설명 |
|
---|---|---|
레코드를 UDP 데이터그램 패킷으로 형식화하여 구성 가능한 대상으로 보내기 |
V¶
컨트롤러 |
설명 |
|
---|---|---|
최소 최근 사용 알고리즘을 기반으로 요소를 제거하는 스키마 캐시를 제공합니다. |
W¶
컨트롤러 |
설명 |
|
---|---|---|
Windows Event Log 데이터를 ConsumeWindowsEventLog, ParseEvtx 등에 의해 생성된 XML 형식의 콘텐츠로 읽습니다. |
X¶
컨트롤러 |
설명 |
|
---|---|---|
재로드 가능한 XML 파일 기반 조회 서비스입니다. |
||
XML 내용을 읽고 레코드 오브젝트를 생성합니다. |
||
RecordSet 을 XML 에 작성합니다. |
Y¶
컨트롤러 |
설명 |
|
---|---|---|
YAML 을 개별 레코드 오브젝트로 구문 분석합니다. |