모든 컨트롤러(알파벳순)

이 항목에서는 알파벳 순으로 모든 openflow 컨트롤러 목록을 제공합니다. 이 목록은 다음을 포함합니다.

  • 컨트롤러 유형(Snowflake 여부)

  • 각 컨트롤러의 이름

  • 각 컨트롤러에 대한 요약

A

컨트롤러

설명

ADLSCredentialsControllerService

ADLS 프로세서에 대한 자격 증명을 정의합니다.

ADLSCredentialsControllerServiceLookup

다른 ADLSCredentialsService 를 동적으로 선택하는 데 사용할 수 있는 ADLSCredentialsService 공급자를 제공합니다.

AmazonGlueSchemaRegistry

AWS Glue Schema Registry와 상호 작용하는 Schema Registry를 제공하여 Glue Schema Registry에 저장된 스키마를 NiFi 에서 사용할 수 있도록 합니다.

AmazonMSKConnectionService

공급자 또는 컨슈머 작업을 위해 AWS MSK Kafka Brokers에 대한 연결을 제공하고 관리합니다.

Snowflake

AmazonMSKConnectionService

공급자 또는 컨슈머 작업을 위해 AWS MSK Kafka Brokers에 대한 연결을 제공하고 관리합니다.

ApicurioSchemaRegistry

Apicurio Schema Registry와 상호 작용하는 Schema Registry를 제공하여 Apicurio Schema Registry에 저장된 스키마를 NiFi 에서 사용할 수 있도록 합니다.

AvroReader

Avro 데이터를 구문 분석하고 각 Avro 레코드를 별도의 레코드 오브젝트로 반환합니다.

AvroRecordSetWriter

RecordSet 의 내용을 이진 Avro 형식으로 작성합니다.

AvroSchemaRegistry

스키마 등록 및 액세스를 위한 서비스를 제공합니다.

AWSCredentialsProviderControllerService

Amazon Web Services 프로세서에 대한 자격 증명을 정의합니다.

AzureBlobStorageFileResourceService

다른 구성 요소에 대한 Azure Blob Storage 파일 리소스를 제공합니다.

AzureCosmosDBClientService

Cosmos DB(Core SQL API)에 대한 연결을 구성하고 다른 Cosmos DB 관련 구성 요소에 해당 연결에 대한 액세스를 제공하는 컨트롤러 서비스를 제공합니다.

AzureDataLakeStorageFileResourceService

다른 구성 요소에 대한 Azure Data Lake Storage(ADLS) 파일 리소스를 제공합니다.

AzureEventHubRecordSink

레코드 형식 지정 및 Azure Event Hubs로 보내기

AzureStorageCredentialsControllerService_v12

Azure Storage 클라이언트 라이브러리 v12를 사용하여 Azure Storage 프로세서에 대한 자격 증명을 제공합니다.

AzureStorageCredentialsControllerServiceLookup_v12

다른 AzureStorageCredentialsService_v12를 동적으로 선택하는 데 사용할 수 있는 AzureStorageCredentialsService_v12를 제공합니다.

C

컨트롤러

설명

CEFReader

CEF (공통 이벤트 형식) 이벤트를 구문 분석하여 각 행을 레코드로 반환합니다.

ConfluentEncodedSchemaReferenceReader

바이트 마커와 4바이트로 표현되는 정수로 구성된 헤더로 Confluent 인코딩에 따라 스키마 식별자를 읽습니다.

ConfluentEncodedSchemaReferenceWriter

바이트 마커와 4바이트로 표현되는 정수로 구성된 헤더로 Confluent 인코딩에 따라 스키마 식별자를 씁니다.

ConfluentSchemaRegistry

Confluent Schema Registry에 저장된 스키마를 NiFi 에서 사용할 수 있도록 Confluent Schema Registry와 상호 작용하는 Schema Registry를 제공합니다.

CSVReader

CSV 형식의 데이터를 구문 분석하여 CSV 파일의 각 행을 별도의 레코드로 반환합니다.

CSVRecordLookupService

재로드 가능한 CSV 파일 기반 조회 서비스입니다.

CSVRecordSetWriter

RecordSet 의 내용을 CSV 데이터로 씁니다.

D

컨트롤러

설명

Snowflake

DatabaseLookup

사용자가 지정한 SQL 문을 사용하여 데이터베이스를 보강할 수 있는 조회 서비스입니다.

DatabaseRecordLookupService

관계형 데이터베이스 기반 조회 서비스입니다.

DatabaseRecordSink

구성된 데이터베이스 연결을 사용하여 레코드를 작성하는 서비스를 제공합니다.

DBCPConnectionPool

데이터베이스 연결 풀링 서비스를 제공합니다.

DBCPConnectionPoolLookup

다른 DBCPService 를 동적으로 선택하는 데 사용할 수 있는 DBCPService 를 제공합니다.

DeveloperBoxClientService

Box API 호출을 사용할 수 있는 Box 클라이언트 오브젝트를 제공합니다.

DistributedMapCacheLookupService

키에 연결된 값을 검색할 분산 맵 캐시 클라이언트를 선택할 수 있습니다.

E

컨트롤러

설명

ElasticSearchClientServiceImpl

Elasticsearch (하위 수준) REST 클라이언트를 사용하여 Elasticsearch 클라이언트에 액세스하기 위한 컨트롤러 서비스입니다.

ElasticSearchLookupService

지정된 문서 ID 와 연결된 Elasticsearch 서버에서 레코드를 조회합니다.

ElasticSearchStringLookupService

지정된 문서 ID 와 연결된 Elasticsearch 서버에서 문자열 값을 조회합니다.

EmailRecordSink

지정된 형식의 작성기를 사용하여 이메일로 레코드를 전송하는 데 사용할 수 있는 RecordSinkService 공급자를 제공합니다.

EmbeddedHazelcastCacheManager

임베디드 Hazelcast을 실행하고 이를 통해 캐시 인스턴스를 제공하는 서비스입니다.

ExcelReader

Microsoft Excel 문서를 구문 분석하여 각 시트의 각 행을 별도의 레코드로 반환합니다.

ExternalHazelcastCacheManager

NiFi 의 외부에서 실행되는 Hazelcast가 지원하는 캐시 인스턴스를 제공하는 서비스입니다.

F

컨트롤러

설명

FreeFormTextRecordSetWriter

RecordSet 의 내용을 자유 형식 텍스트로 작성합니다.

G

컨트롤러

설명

GCPCredentialsControllerService

Google Cloud Platform 프로세서에 대한 자격 증명을 정의합니다.

GCSFileResourceService

다른 구성 요소를 위한 Google Compute Storage(GCS) 파일 리소스를 제공합니다.

GrokReader

로그 파일과 같은 비정형 텍스트 데이터를 읽고 처리할 수 있도록 데이터를 구조화하기 위한 메커니즘을 제공합니다.

H

컨트롤러

설명

HazelcastMapCacheClient

Hazelcast를 백업 캐시로 사용하는 DistributedMapCacheClient 구현입니다.

HikariCPConnectionPool

HikariCP 를 기반으로 데이터베이스 연결 풀링 서비스를 제공합니다.

HttpRecordSink

HTTP post를 사용하여 레코드를 형식화하고 구성된 URL로 전송합니다.

I

컨트롤러

설명

IPLookupService

IP 주소에 대한 여러 유형의 보강 정보를 제공하는 조회 서비스입니다.

J

컨트롤러

설명

JettyWebSocketClient

WebSocketClientService 의 구현입니다.

JettyWebSocketServer

WebSocketServerService 의 구현입니다.

JMSConnectionFactoryProvider

공급업체별 Javascript를 생성하기 위한 일반 서비스를 제공합니다.

JndiJmsConnectionFactoryProvider

Java 네이밍 및 디렉터리 인터페이스(JNDI)를 사용하여 기존 JMS ConnectionFactory 를 조회하는 서비스를 제공합니다.

JsonConfigBasedBoxClientService

Box API 호출을 사용할 수 있는 Box 클라이언트 오브젝트를 제공합니다.

JsonPathReader

JSON 을 구문 분석하여 각 JSON 오브젝트에 대해 사용자 정의된 JSON 경로를 기록하고 평가합니다.

JsonRecordSetWriter

RecordSet 의 결과를 JSON 배열 또는 한 줄당 1개의 JSON 오브젝트로 씁니다.

Snowflake

JsonTableColumnFilter

JSON 구성을 기반으로 테이블 열 필터를 제공합니다.

JsonTreeReader

JSON 을 개별 레코드 오브젝트로 구문 분석합니다.

JWTBearerOAuth2AccessTokenProvider

OAuth 2를 제공합니다.

K

컨트롤러

설명

Kafka3ConnectionService

공급자 또는 컨슈머 작업을 위해 Kafka Broker에 대한 연결을 제공하고 관리합니다.

Snowflake

Kafka3ConnectionService

공급자 또는 컨슈머 작업을 위해 Kafka Broker에 대한 연결을 제공하고 관리합니다.

L

컨트롤러

설명

LoggingRecordSink

애플리케이션 로그(nifi-app)에 레코드를 기록하는 데 사용할 수 있는 RecordSinkService 공급자를 제공합니다.

M

컨트롤러

설명

MapCacheClientService

MapCacheServer 와 통신하는 기능을 제공합니다.

MapCacheServer

소켓을 통해 액세스할 수 있는 매핑(키/값) 캐시를 제공합니다.

Snowflake

MicrosoftClientCertificateOAuth2TokenProvider

클라이언트 인증서와 함께 클라이언트_크레덴셜을 사용하여 Microsoft 그래프 API 에 대한 OAuth2 액세스 토큰을 제공합니다.

Snowflake

MicrosoftGraphAuthenticationProvider

Microsoft 365 서비스와 상호 작용하는 데 사용할 수 있는 Microsoft Graph API 에 대한 인증을 제공합니다.

MongoDBControllerService

MongoDB 에 대한 연결을 구성하고 다른 Mongo 관련 구성 요소에 해당 연결에 대한 액세스를 제공하는 컨트롤러 서비스를 제공합니다.

MongoDBLookupService

MongoDB 을 기반으로 조회 서비스를 제공합니다.

P

컨트롤러

설명

Snowflake

ParquetIcebergWriter

Apache Parquet 형식을 사용하여 Apache Iceberg에 레코드 직렬화를 제공합니다.

PEMEncodedSSLContextProvider

SSLContext 공급자는 PEM 개인 키 및 인증서 파일을 사용하여 구성할 수 있습니다.

Snowflake

PolarisIcebergCatalog

Apache Iceberg와 Apache Polaris 카탈로그를 통합하여 REST HTTP 에 대한 액세스를 제공합니다.

PropertiesFileLookupService

재로드 가능한 속성 파일 기반 조회 서비스

R

컨트롤러

설명

ReaderLookup

다른 RecordReaderFactory 를 동적으로 선택하는 데 사용할 수 있는 RecordReaderFactory 를 제공합니다.

RecordSetWriterLookup

다른 RecordSetWriterFactory 를 동적으로 선택하는 데 사용할 수 있는 RecordSetWriterFactory 를 제공합니다.

RecordSinkServiceLookup

다른 RecordSinkService 를 동적으로 선택하는 데 사용할 수 있는 RecordSinkService 를 제공합니다.

RedisConnectionPoolService

Redis에 연결을 제공하는 서비스입니다.

RedisDistributedMapCacheClientService

Redis를 백업 캐시로 사용하는 DistributedMapCacheClient 구현입니다.

RestLookupService

REST 서비스를 사용하여 값을 조회합니다.

S

컨트롤러

설명

S3FileResourceService

다른 구성 요소에 대한 Amazon Web Services(AWS) S3 파일 리소스를 제공합니다.

Snowflake

SalesforceDataCloudOAuthTokenProvider

구성된 OAuth2 액세스 토큰 공급자를 사용하여 Salesforce에서 OAuth2 액세스 토큰을 검색하고 해당 토큰을 데이터 클라우드 API 토큰으로 교환합니다.

ScriptedLookupService

사용자가 수신 플로우 파일에서 레코드를 보강하기 위해 스크립트화된 LookupService 인스턴스를 제공할 수 있습니다.

ScriptedReader

사용자가 수신 플로우 파일에서 레코드를 읽기/구문 분석/생성하기 위해 스크립트화된 RecordReaderFactory 인스턴스를 제공할 수 있습니다.

ScriptedRecordSetWriter

사용자가 발신 플로우 파일에 레코드를 쓰기 위해 스크립트화된 RecordSetWriterFactory 인스턴스를 제공할 수 있습니다.

ScriptedRecordSink

사용자가 원하는 대상으로 레코드를 전송하기 위해 스크립트화된 RecordSinkService 인스턴스를 제공할 수 있습니다.

SetCacheClientService

SetCacheServer 와 통신하는 기능을 제공합니다.

SetCacheServer

소켓을 통해 액세스할 수 있는 세트(고유 값 모음) 캐시를 제공합니다.

SimpleCsvFileLookupService

재로드 가능한 CSV 파일 기반 조회 서비스입니다.

SimpleDatabaseLookupService

관계형 데이터베이스 기반 조회 서비스입니다.

SimpleKeyValueLookupService

사용자가 키-값 페어를 사용자 정의 속성으로 추가할 수 있습니다.

SimpleRedisDistributedMapCacheClientService

Redis를 백업 캐시로 사용하는 DistributedMapCacheClient 구현입니다.

SimpleScriptedLookupService

사용자가 수신 플로우 파일에서 레코드를 보강하기 위해 스크립트화된 LookupService 인스턴스를 제공할 수 있습니다.

SlackRecordSink

Slack Post Message API 를 사용하여 구성된 채널에 레코드의 형식을 지정하고 전송합니다.

SmbjClientProviderService

공유 인증 자격 증명을 사용하여 SMB 세션에 대한 액세스를 제공합니다.

Snowflake

SnowflakeConnectionService

Snowflake 서비스에 풀링된 데이터베이스 연결을 제공합니다

Snowflake

SnowflakeDatabaseDialectService

Snowflake를 지원하는 데이터베이스 언어 서비스.

Snowflake

SnowflakeSignJWTService

Snowflake

SnowflakeTableSchemaRegistry

Snowflake

StandardAnthropicLLMService

메시지 API 를 통해 Anthropic의 Claude AI 모델과 통합을 제공하는 컨트롤러 서비스입니다.

StandardAzureCredentialsControllerService

Azure 클라이언트에서 사용할 자격 증명을 제공합니다.

Snowflake

StandardDatabricksWorkspaceClientService

Databricks 클라이언트.

StandardDropboxCredentialService

Dropbox 프로세서에 대한 자격 증명을 정의합니다.

StandardFileResourceService

다른 구성 요소에 대한 파일 리소스를 제공합니다.

StandardHashiCorpVaultClientService

HashiCorp Vault와 상호 작용하기 위한 컨트롤러 서비스입니다.

StandardHttpContextMap

프로세서 외부에 HTTP 요청 및 응답을 저장하고 검색하는 기능을 제공하여 여러 프로세서가 동일한 HTTP 요청과 상호 작용할 수 있도록 합니다.

Snowflake

StandardHubSpotClientService

HubSpot HTTP API와 통합할 HubSpot 컨트롤러 서비스입니다.

StandardJsonSchemaRegistry

JSON 스키마 등록 및 액세스를 위한 서비스를 제공합니다.

StandardKustoIngestService

flowfile 내용 배치 또는 스트림 flowfile 내용을 Azure ADX 클러스터로 보냅니다.

StandardKustoQueryService

Azure Data Explorer를 위한 Kusto 쿼리 서비스의 표준 구현

Snowflake

StandardMilvusConnectionService

Milvus 인스턴스에 연결 서비스를 제공합니다

StandardOauth2AccessTokenProvider

OAuth 2를 제공합니다.

Snowflake

StandardOCRService

Openflow OCR 서비스에 대한 통합을 제공합니다

Snowflake

StandardOpenAILLMService

OpenAI 의 Chat Completion API 와 통합을 제공하는 컨트롤러 서비스입니다.

StandardPGPPrivateKeyService

PGP 개인 키 서비스는 파일 또는 속성에서 로딩된 개인 키를 제공합니다

StandardPGPPublicKeyService

파일에서 로딩된 공개 키를 제공하는 PGP 공개 키 서비스 공급자

StandardPrivateKeyService

개인 키 서비스는 구성된 소스에서 로딩된 개인 키에 대한 액세스를 제공합니다

StandardProxyConfigurationService

프록시 서버를 사용하기 위한 다양한 NiFi 구성 요소에 대한 구성 세트를 제공합니다.

StandardRestrictedSSLContextService

SSLContextService 의 제한적 구현.

StandardS3EncryptionService

S3 Put 및 S3 Fetch 작업에 구성 가능한 암호화를 추가합니다.

Snowflake

StandardSalesforceClientService

Salesforce APIs 에 연결 서비스 제공

Snowflake

StandardSalesforceDataCloudClientService

Salesforce Data Cloud APIs 에 연결 서비스 제공

StandardSSLContextService

SSLContextService 의 표준 구현.

Snowflake

StandardTableStateService

테이블 상태를 제공하고 관리하는 컨트롤러 서비스입니다.

Snowflake

StandardVectaraClientService

Vectara HTTP API를 통합하기 위한 Vectara 컨트롤러 서비스.

StandardWebClientServiceProvider

표준 HTTP 연결 속성 구성을 지원하는 웹 클라이언트 서비스 공급자

Snowflake

StateManagedCdcSchemaRegistry

기본 제공 NiFi 상태 관리를 사용하여 테이블 스키마의 해시를 저장합니다.

Syslog5424Reader

로그 파일과 같은 RFC 5424 호환 Syslog 데이터를 읽고 처리할 수 있도록 데이터를 구조화하기 위한 메커니즘을 제공합니다.

SyslogReader

RFC5424 및 RFC3164 에 따라 Syslog 메시지의 내용을 구문 분석하려고 시도합니다.

U

컨트롤러

설명

UDPEventRecordSink

레코드를 UDP 데이터그램 패킷으로 형식화하여 구성 가능한 대상으로 보내기

V

컨트롤러

설명

VolatileSchemaCache

최소 최근 사용 알고리즘을 기반으로 요소를 제거하는 스키마 캐시를 제공합니다.

W

컨트롤러

설명

WindowsEventLogReader

Windows Event Log 데이터를 ConsumeWindowsEventLog, ParseEvtx 등에 의해 생성된 XML 형식의 콘텐츠로 읽습니다.

X

컨트롤러

설명

XMLFileLookupService

재로드 가능한 XML 파일 기반 조회 서비스입니다.

XMLReader

XML 내용을 읽고 레코드 오브젝트를 생성합니다.

XMLRecordSetWriter

RecordSet 을 XML 에 작성합니다.

Y

컨트롤러

설명

YamlTreeReader

YAML 을 개별 레코드 오브젝트로 구문 분석합니다.