Openflow 컨트롤러 서비스 목록
Openflow 컨트롤러 서비스 목록 (알파벳순)
Snowflake Openflow가 제공하는 모든 컨트롤러 서비스를 알파벳순으로 정리한 목록 페이지예요. 각 컨트롤러 서비스의 유형, 이름, 요약을 한눈에 살펴볼 수 있어요.
출처: 문서
본문
이 주제에서는 모든 Openflow 컨트롤러 서비스를 알파벳순으로 나열해요. 목록에 포함되는 내용은 다음과 같아요.
- 컨트롤러 서비스의 유형(Snowflake 여부)
- 각 컨트롤러 서비스의 이름
- 각 컨트롤러 서비스의 요약
A
| 컨트롤러 | 설명 |
|---|---|
| ADLSCredentialsControllerService | ADLS 프로세서용 자격 증명을 정의해요. |
| ADLSCredentialsControllerServiceLookup | 다른 ADLSCredentialsService를 동적으로 선택할 수 있는 서비스를 제공해요. |
| AmazonGlueEncodedSchemaReferenceReader | 두 바이트 마커와 16바이트 UUID로 구성된 헤더에 따라 AWS Glue Schema 인코딩으로 Schema Identifier를 읽어요. |
| AmazonGlueSchemaRegistry | AWS Glue Schema Registry와 상호작용하는 Schema Registry를 제공해서, Glue Schema Registry에 저장된 스키마를 NiFi에서 사용할 수 있게 해요. |
| AmazonMSKConnectionService | 프로듀서/컨슈머 작업을 위해 AWS MSK Kafka 브로커에 대한 연결을 제공하고 관리해요. 워크로드 아이덴티티 페더레이션에는 이 서비스를 사용하세요. |
| AmazonMSKConnectionService | 더 이상 사용되지 않음(Deprecated). 워크로드 아이덴티티 페더레이션을 지원하지 않아요. Snowflake 배지가 없는 서비스를 대신 사용하세요. |
| ApicurioSchemaRegistry | Apicurio Schema Registry와 상호작용하는 Schema Registry를 제공해서, Apicurio Schema Registry에 저장된 스키마를 NiFi에서 사용할 수 있게 해요. |
| AvroReader | Avro 데이터를 파싱하고 각 Avro 레코드를 별도의 Record 객체로 반환해요. |
| AvroRecordSetWriter | RecordSet의 내용을 Binary 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를 동적으로 선택할 수 있는 서비스를 제공해요. |
C
| 컨트롤러 | 설명 |
|---|---|
| CEFReader | CEF(Common Event Format) 이벤트를 파싱하고 각 행을 레코드로 반환해요. |
| ConfluentEncodedSchemaReferenceReader | 바이트 마커와 4바이트 정수로 구성된 헤더에 따라 Confluent 인코딩으로 Schema Identifier를 읽어요. |
| ConfluentEncodedSchemaReferenceWriter | 바이트 마커와 4바이트 정수로 구성된 헤더에 따라 Confluent 인코딩으로 Schema Identifier를 써요. |
| ConfluentProtobufMessageNameResolver | 메시지 인덱스를 디코딩하고 스키마 정의에서 정규화된 이름을 조회해서, Confluent Schema Registry 와이어 형식에서 Protobuf 메시지 이름을 해석해요. |
| ConfluentSchemaRegistry | Confluent Schema Registry와 상호작용하는 Schema Registry를 제공해서, Confluent Schema Registry에 저장된 스키마를 NiFi에서 사용할 수 있게 해요. |
| CSVReader | CSV 형식 데이터를 파싱하고 CSV 파일의 각 행을 별도의 레코드로 반환해요. |
| CSVRecordLookupService | 다시 불러올 수 있는 CSV 파일 기반 조회 서비스예요. |
| CSVRecordSetWriter | RecordSet의 내용을 CSV 데이터로 작성해요. |
D
| 컨트롤러 | 설명 |
|---|---|
| DatabaseLookup | 사용자가 지정한 SQL 문으로 데이터베이스를 사용해 강화(enrichment)할 수 있게 하는 Lookup Service예요. |
| DatabaseRecordLookupService | 관계형 데이터베이스 기반 조회 서비스예요. |
| DatabaseRecordSink | 설정된 데이터베이스 연결을 사용해 레코드를 쓰는 서비스를 제공해요. |
| DBCPConnectionPool | 데이터베이스 커넥션 풀링 서비스를 제공해요. |
| DBCPConnectionPoolLookup | 다른 DBCPService를 동적으로 선택할 수 있는 서비스를 제공해요. |
| DeveloperBoxClientService | Box API 호출에 사용할 수 있는 Box 클라이언트 객체를 제공해요. |
| DistributedMapCacheLookupService | 키에 연결된 값을 검색할 분산 맵 캐시 클라이언트를 선택하게 해요. |
E
| 컨트롤러 | 설명 |
|---|---|
| ElasticSearchClientServiceImpl | Elasticsearch(저수준) REST 클라이언트를 사용해 Elasticsearch 클라이언트에 접근하는 컨트롤러 서비스예요. |
| ElasticSearchLookupService | 지정된 문서 ID와 연결된 Elasticsearch 서버에서 레코드를 조회해요. |
| ElasticSearchStringLookupService | 지정된 문서 ID와 연결된 Elasticsearch 서버에서 문자열 값을 조회해요. |
| EmailRecordSink | 지정된 writer로 포맷해 이메일로 레코드를 보내는 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로 설정된 URI로 보내요. |
I
| 컨트롤러 | 설명 |
|---|---|
| IPLookupService | IP 주소에 대한 여러 유형의 강화 정보를 제공하는 조회 서비스예요. |
J
| 컨트롤러 | 설명 |
|---|---|
| JettyWebSocketClient | WebSocketClientService 구현체예요. |
| JettyWebSocketServer | WebSocketServerService 구현체예요. |
| JMSConnectionFactoryProvider | 벤더별 javax.jms ConnectionFactory 구현체를 만드는 일반 서비스를 제공해요. |
| JndiJmsConnectionFactoryProvider | Java Naming and Directory Interface(JNDI)를 사용해 기존 JMS ConnectionFactory를 조회하는 서비스를 제공해요. |
| JsonConfigBasedBoxClientService | Box API 호출에 사용할 수 있는 Box 클라이언트 객체를 제공해요. |
| JsonPathReader | JSON 레코드를 파싱하고 각 JSON 객체에 대해 사용자가 정의한 JSON Path를 평가해요. |
| JsonRecordSetWriter | RecordSet의 결과를 JSON 배열 또는 한 줄에 JSON 객체 하나로 작성해요. |
| JsonTableColumnFilter | JSON 설정 기반의 테이블 컬럼 필터를 제공해요. |
| JsonTreeReader | JSON을 개별 Record 객체로 파싱해요. |
| JWTBearerOAuth2AccessTokenProvider | HTTP 요청의 Bearer 인증 헤더로 사용할 수 있는 OAuth 2.0 액세스 토큰을 제공해요. |
K
| 컨트롤러 | 설명 |
|---|---|
| Kafka3ConnectionService | 프로듀서/컨슈머 작업을 위해 Kafka 브로커에 대한 연결을 제공하고 관리해요. |
| Kafka3ConnectionService | 프로듀서/컨슈머 작업을 위해 Kafka 브로커에 대한 연결을 제공하고 관리해요. |
L
| 컨트롤러 | 설명 |
|---|---|
| LoggingRecordSink | 지정된 writer로 포맷해 애플리케이션 로그(예: nifi-app.log)에 레코드를 기록하는 RecordSinkService를 제공해요. |
M
| 컨트롤러 | 설명 |
|---|---|
| MapCacheClientService | MapCacheServer와 통신할 수 있는 기능을 제공해요. |
| MapCacheServer | 소켓을 통해 접근할 수 있는 맵(key/value) 캐시를 제공해요. |
| MicrosoftClientCertificateOAuth2TokenProvider | 클라이언트 인증서를 사용한 client_credentials 방식을 통해 Microsoft Graph API용 OAuth2 액세스 토큰을 제공해요. |
| MicrosoftGraphAuthenticationProvider | Microsoft 365 서비스와 상호작용하는 데 사용할 수 있는 Microsoft Graph API 인증을 제공해요. |
| MongoDBControllerService | MongoDB에 대한 연결을 설정하는 컨트롤러 서비스를 제공하고, 그 연결을 다른 Mongo 관련 컴포넌트에 노출해요. |
| MongoDBLookupService | MongoDB 기반 조회 서비스를 제공해요. |
P
| 컨트롤러 | 설명 |
|---|---|
| ParquetIcebergWriter | Apache Parquet 형식을 사용해 Apache Iceberg용 레코드 직렬화를 제공해요. |
| PEMEncodedSSLContextProvider | PEM 개인 키와 인증서 파일로 설정 가능한 SSLContext Provider예요. |
| PolarisIcebergCatalog | REST HTTP를 통한 Apache Polaris Catalog 접근으로 Apache Iceberg 통합을 제공해요. |
| PropertiesFileLookupService | 다시 불러올 수 있는 properties 파일 기반 조회 서비스예요. |
| ProtobufReader | 바이너리 형식의 Protocol Buffers 메시지를 파싱해요. |
R
| 컨트롤러 | 설명 |
|---|---|
| ReaderLookup | 다른 RecordReaderFactory를 동적으로 선택할 수 있는 RecordReaderFactory를 제공해요. |
| RecordSetWriterLookup | 다른 RecordSetWriterFactory를 동적으로 선택할 수 있는 RecordSetWriterFactory를 제공해요. |
| RecordSinkServiceLookup | 다른 RecordSinkService를 동적으로 선택할 수 있는 RecordSinkService를 제공해요. |
| RedisConnectionPoolService | Redis에 대한 연결을 제공하는 서비스예요. |
| RedisDistributedMapCacheClientService | Redis를 백업 캐시로 사용하는 DistributedMapCacheClient 구현체예요. |
| RemoveFieldRecordReader | NiFi Records에서 지정된 필드를 걸러내는 Filtering을 지원하는 RecordReaderFactory 래퍼예요. |
| RestLookupService | REST 서비스를 사용해 값을 조회해요. |
S
| 컨트롤러 | 설명 |
|---|---|
| S3FileResourceService | 다른 컴포넌트에 Amazon Web Services(AWS) S3 파일 리소스를 제공해요. |
| SalesforceDataCloudOAuthTokenProvider | 설정된 OAuth2 Access Token Provider를 사용해 Salesforce에서 OAuth2 액세스 토큰을 가져오고, 그 토큰을 Data Cloud API 토큰으로 교환해요. 그런 다음 그 토큰을 사용해 Salesforce Data Cloud 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 세션에 대한 접근을 제공해요. |
| SnowflakeConnectionService | Snowflake 서비스에 풀링된 데이터베이스 연결을 제공해요. |
| SnowflakeDatabaseDialectService | Snowflake를 지원하는 Database Dialect Service예요. |
| SnowflakeSignJWTService | Snowflake에 저장된 비밀 키로 서명된 JWT를 사용해 OAuth2 액세스 토큰을 제공해요. |
| SnowflakeTableSchemaRegistry | Snowflake 테이블을 스키마의 원천으로 사용해요. Snowpipe Streaming REST API를 활용해요. |
| StandardAnthropicLLMService | Messages API를 통해 Anthropic의 Claude AI 모델과 통합을 제공하는 Controller Service예요. |
| StandardAtlassianRequestRateManager | 프로세서 간 Atlassian API 호출에 대한 속도 제한을 조정해 연쇄적인 속도 제한 문제를 방지해요. |
| StandardAzureCredentialsControllerService | Azure 클라이언트에 사용할 자격 증명을 제공해요. |
| StandardConfluenceClientService | Confluence API에 대한 연결 서비스를 제공해요. |
| StandardDatabricksWorkspaceClientService | Databricks 클라이언트예요. |
| StandardDropboxCredentialService | Dropbox 프로세서용 자격 증명을 정의해요. |
| StandardFileResourceService | 다른 컴포넌트에 파일 리소스를 제공해요. |
| StandardHashiCorpVaultClientService | HashiCorp Vault와 상호작용하는 컨트롤러 서비스예요. |
| StandardHttpContextMap | HTTP 요청과 응답을 프로세서 외부에 저장하고 검색할 수 있는 기능을 제공해서, 여러 프로세서가 같은 HTTP 요청으로 상호작용할 수 있게 해요. |
| StandardHubSpotClientService | HubSpot HTTP API와 통합하는 HubSpot Controller Service예요. |
| StandardJsonSchemaRegistry | JSON 스키마를 등록하고 접근하는 서비스를 제공해요. |
| StandardKustoIngestService | 플로우 파일 콘텐츠 배치 또는 스트림을 Azure ADX 클러스터로 전송해요. |
| StandardKustoQueryService | Azure Data Explorer용 Kusto Query Service의 표준 구현체예요. |
| StandardMilvusConnectionService | Milvus 인스턴스에 대한 연결 서비스를 제공해요. |
| StandardOauth2AccessTokenProvider | OAuth 2.0 액세스 토큰을 제공해요. |
| StandardOCRService | Openflow OCR 서비스에 대한 통합을 제공해요. |
| StandardOpenAILLMService | OpenAI의 Chat Completion API와 통합을 제공하는 Controller Service예요. |
| StandardPGPPrivateKeyService | 파일 또는 속성에서 로드한 개인 키를 제공하는 PGP Private Key Service예요. |
| StandardPGPPublicKeyService | 파일에서 로드한 공개 키를 제공하는 PGP Public Key Service예요. |
| StandardPrivateKeyService | 설정된 소스에서 로드한 개인 키에 대한 접근을 제공하는 Private Key Service예요. |
| StandardProtobufReader | 바이너리 형식의 Protocol Buffers 메시지를 NiFi Records로 파싱해요. |
| StandardProxyConfigurationService | 서로 다른 NiFi 컴포넌트가 프록시 서버를 사용할 수 있도록 설정 모음을 제공해요. |
| StandardRestrictedSSLContextService | SSLContextService의 제한된 구현체예요. |
| StandardS3EncryptionService | S3 Put 및 S3 Fetch 작업에 설정 가능한 암호화를 추가해요. |
| StandardSalesforceBulkJobsStateService | 클러스터 범위에서 객체 유형별 Salesforce Bulk Jobs 상태를 저장해요. |
| StandardSalesforceClientService | Salesforce API에 대한 연결 서비스를 제공해요. |
| StandardSalesforceDataCloudClientService | Salesforce Data Cloud API에 대한 연결 서비스를 제공해요. |
| StandardSlackRateLimiterService | Slack API 호출에 대한 속도 제한을 조정해 연쇄적인 속도 제한 문제를 방지해요. |
| StandardSSLContextService | SSLContextService의 표준 구현체예요. |
| StandardTableStateService | 테이블 상태를 제공하고 관리하는 Controller Service예요. |
| StandardVectaraClientService | Vectara HTTP API와 통합하는 Vectara Controller Service예요. |
| StandardWebClientServiceProvider | 표준 HTTP 연결 속성 설정을 지원하는 Web Client Service Provider예요. |
| StateManagedCdcSchemaRegistry | 테이블 스키마의 해시를 저장하기 위해 NiFi 내장 State Management를 사용해요. |
| Syslog5424Reader | RFC 5424를 준수하는 Syslog 데이터(예: 로그 파일)를 읽고 처리 가능하도록 구조화하는 메커니즘을 제공해요. |
| SyslogReader | RFC5424와 RFC3164에 따라 Syslog 메시지 내용을 파싱하려 시도해요. |
U
| 컨트롤러 | 설명 |
|---|---|
| UDPEventRecordSink | 레코드를 포맷해서 UDP 데이터그램 패킷으로 설정 가능한 대상에 전송해요. |
V
| 컨트롤러 | 설명 |
|---|---|
| VolatileSchemaCache | Least-Recently-Used 알고리즘을 기반으로 요소를 퇴거(evict)하는 Schema Cache를 제공해요. |
W
| 컨트롤러 | 설명 |
|---|---|
| WindowsEventLogReader | ConsumeWindowsEventLog, ParseEvtx 등이 생성한 XML 콘텐츠로 Windows Event Log 데이터를 읽어요. |
X
| 컨트롤러 | 설명 |
|---|---|
| XMLFileLookupService | 다시 불러올 수 있는 XML 파일 기반 조회 서비스예요. |
| XMLReader | XML 콘텐츠를 읽고 Record 객체를 만들어요. |
| XMLRecordSetWriter | RecordSet을 XML로 작성해요. |
Y
| 컨트롤러 | 설명 |
|---|---|
| YamlTreeReader | YAML을 개별 Record 객체로 파싱해요. |