모든 프로세서(알파벳순)

이 항목에서는 알파벳 순서대로 모든 Snowflake openflow 프로세서 목록을 제공합니다. 이 목록은 다음을 포함합니다.

  • 각 프로세서의 이름

  • 각 프로세서에 대한 요약

A

프로세서

설명

Snowflake

AbortQueryJob

Bulk API 2를 사용하여 Salesforce에서 쿼리 작업을 중단합니다.

AttributesToCSV

입력 FlowFile 특성의 CSV 표현을 생성합니다.

AttributesToJSON

입력 FlowFile 특성의 JSON 표현을 생성합니다.

C

프로세서

설명

CalculateRecordStats

레코드 세트의 레코드 수를 계산하며, 선택적으로 카테고리별 요소 수를 계산합니다(여기서 카테고리는 사용자 정의 속성에 의해 정의됨).

Snowflake

CaptureChangeMySQL

MySQL 데이터베이스에서 CDC 이벤트를 읽습니다.

Snowflake

CaptureChangePostgreSQL

PostgreSQL 데이터베이스에서 CDC 이벤트를 읽습니다.

Snowflake

CaptureChangeSqlServer

SQL 서버 데이터베이스에서 CDC 이벤트를 읽습니다.

Snowflake

CaptureGoogleDriveChanges

Shared Google Drive의 변경 내용을 캡처하고 변경 사항이 발생할 때마다 FlowFile 을 전송합니다.

Snowflake

CaptureMicrosoft365GroupsChanges

Microsoft 365 그룹의 변경 사항을 감지하고 각 변경 사항에 대해 FlowFile 을 전송합니다.

Snowflake

CaptureSharepointChanges

SharePoint 문서 라이브러리에서 변경 내용을 캡처하고 변경이 발생할 때마다 FlowFile 을 전송합니다.

Snowflake

CheckMetaAdsReportReadiness

프로세서가 Meta Ads 보고서를 다운로드할 준비가 되었는지 확인합니다.

Snowflake

ChunkRecordText

구분 기호 및 최대 문자 길이로 재귀적으로 분할하는 옵션이 있는 청크 텍스트입니다.

Snowflake

ChunkText

구분 기호 및 최대 문자 길이로 재귀적으로 분할하는 옵션이 있는 청크 텍스트입니다.

CompressContent

사용자가 지정한 압축 알고리즘을 사용하여 FlowFiles 의 내용을 압축 또는 압축 해제하고 MIME을 업데이트합니다.

ConnectWebSocket

원격 WebSocket 서버와 상호 작용하는 WebSocket 클라이언트 엔드포인트의 역할을 합니다.

ConsumeAMQP

AMQP 0을 사용하여 AMQP 브로커의 AMQP 메시지를 소비합니다.

ConsumeAzureEventHub

일관된 이벤트 처리를 보장하기 위해 체크포인팅을 통해 Microsoft Azure Event Hubs에서 메시지를 수신합니다.

ConsumeBoxEnterpriseEvents

Box admin_logs_streaming 스트림 유형에서 엔터프라이즈 이벤트를 소비합니다.

ConsumeBoxEvents

Box의 모든 이벤트를 소비합니다.

ConsumeElasticsearch

범위 쿼리를 사용하여 필드에 대해 페이지 매김된 쿼리를 반복적으로 실행하여 Elasticsearch 인덱스/쿼리에서 새 문서를 소비하는 프로세서입니다.

ConsumeGCPubSub

구성된 Google Cloud PubSub 구독의 메시지를 소비합니다.

ConsumeIMAP

IMAP 프로토콜을 사용하여 이메일 서버에서 메시지를 소비합니다.

ConsumeJMS

BytesMessage, TextMessage, ObjectMessage, MapMessage 또는 StreamMessage 유형의 JMS 메시지를 소비하여 그 내용을 FlowFile 로 변환하고 ‘성공’ 관계로 전환합니다.

ConsumeKafka

Apache Kafka Consumer API 의 메시지를 소비합니다.

Snowflake

ConsumeKafka

Apache Kafka Consumer API 의 메시지를 소비합니다.

ConsumeKinesisStream

지정된 AWS Kinesis Stream에서 데이터를 읽고 처리된 모든 레코드(원시)에 대해 FlowFile, Record Reader와 Record Writer가 구성된 경우 처리된 레코드 배치에 대해 FlowFile 을 출력합니다.

ConsumeMQTT

항목을 구독하고 MQTT브 로커로부터 메시지를 수신합니다

ConsumePOP3

POP3 프로토콜을 사용하여 이메일 서버에서 메시지를 소비합니다.

ConsumeSlack

구성된 1개 이상의 Slack 채널에서 메시지를 검색합니다.

Snowflake

ConsumeSlackConversation

앱에서 사용 가능한 Slack 대화에서 메시지를 검색합니다.

Snowflake

ConsumeSlackHistory

앱에서 사용 가능한 모든 Slack 채널에서 과거 메시지를 가져옵니다.

Snowflake

ConsumeSnowflakeStream

Snowflake 스트림에서 데이터를 가져와 FlowFile 에 씁니다.

ConsumeTwitter

Twitter의 스트림 API v2에서 트윗을 스트리밍합니다.

ControlRate

후속 프로세서로 데이터를 전송하는 속도를 제어합니다.

ConvertCharacterSet

FlowFile 의 내용을 한 문자 세트에서 다른 문자 세트로 변환합니다

ConvertRecord

구성된 Record Reader 및 레코드 쓰기 컨트롤러 서비스를 사용하여 한 데이터 형식에서 다른 데이터 형식으로 레코드를 변환합니다.

Snowflake

ConvertToJournalSchema

수신 데이터베이스 스키마를 Snowflake CDC Journal 테이블에 적합한 스키마로 변환합니다.

CopyAzureBlobStorage_v12

한 계정/컨테이너에서 다른 계정/컨테이너로 Azure Blob Storage의 Blob을 복사본으로 복사합니다.

CopyS3Object

AWS S3에서 한 버킷과 키에서 다른 버킷과 키로 파일 복사본 만들기

CountText

수신 텍스트에 대한 다양한 메트릭을 계산합니다.

Snowflake

CreateAmazonAdsReport

Amazon Ads 커넥터에 대한 보고서 구성을 생성하는 프로세서입니다.

Snowflake

CreateAzureOpenAiEmbeddings

Azure OpenAI 를 사용하여 텍스트용 임베딩을 생성합니다.

CreateBoxFileMetadataInstance

flowfile 내용의 값으로 지정된 템플릿을 사용하여 Box 파일에 대한 메타데이터 인스턴스를 생성합니다.

CreateBoxMetadataTemplate

flowFile 내용의 필드 사양을 사용하여 Box 메타데이터 템플릿을 생성합니다.

Snowflake

CreateCohereEmbeddings

Cohere를 사용하여 텍스트 임베딩을 생성합니다.

Snowflake

CreateMetaAdsReport

Meta Ads 커넥터에 대한 보고서 구성을 생성하는 프로세서입니다.

Snowflake

CreateOpenAiEmbeddings

OpenAI 를 사용하여 텍스트용 임베딩을 생성합니다.

Snowflake

CreateSnowflakeEmbeddings

Snowflake Cortex Large Language Model 함수를 사용하여 벡터 임베딩 생성하기

Snowflake

CreateVertexAIEmbeddings

VertexAI 를 사용하여 텍스트용 임베딩을 생성합니다.

CryptographicHashContent

주어진 알고리즘을 사용하여 flowfile 내용에 대한 암호화 해시값을 계산하고 출력 특성에 기록합니다.

D

프로세서

설명

DebugFlow

DebugFlow 프로세서는 타이머 또는 cron 기반 스케줄링을 사용하는 경우 FlowFile 없이 FlowFile 또는 타이머 이벤트 수신에 대해 다양한 응답을 명시적으로 트리거할 수 있도록 하여 FlowFile 프레임워크의 테스트 및 디버깅을 지원합니다.

DecryptContentAge

수명 암호화를 사용하여 내용을 해독합니다.

DecryptContentPGP

OpenPGP 메시지의 내용을 해독합니다.

DeduplicateRecord

이 프로세서는 레코드 세트 내의 개별 레코드의 중복을 제거합니다.

DeleteAzureBlobStorage_v12

지정된 Blob을 Azure Blob Storage에서 삭제합니다.

DeleteAzureDataLakeStorage

제공된 파일을 Azure Data Lake Storage에서 삭제합니다

DeleteBoxFileMetadataInstance

지정된 템플릿 키를 사용하여 Box 파일에서 메타데이터 인스턴스를 삭제합니다

DeleteByQueryElasticsearch

쿼리를 사용하여 Elasticsearch 인덱스에서 삭제합니다.

Snowflake

DeleteDBFSResource

DBFS 파일 및 디렉터리를 삭제합니다.

DeleteDynamoDB

해시 및 범위 키에 따라 DynamoDB 에서 문서를 삭제합니다.

DeleteFile

파일 시스템에서 파일을 삭제합니다.

DeleteGCSObject

Google Cloud Bucket에서 오브젝트를 삭제합니다.

DeleteGridFS

파일 이름 또는 쿼리를 사용하여 GridFS 에서 파일을 삭제합니다.

Snowflake

DeleteMilvus

Milvus 데이터베이스에서 ID 에 의해 컬렉션에서 벡터를 삭제합니다.

DeleteMongo

MongoDB 컬렉션에 대해 삭제 쿼리를 실행합니다.

Snowflake

DeletePinecone

Pinecone 인덱스에서 벡터를 삭제합니다.

Snowflake

DeleteQueryJob

Bulk API 2를 사용하여 Salesforce에서 쿼리 작업을 삭제합니다.

DeleteS3Object

Amazon S3 버킷에서 파일을 삭제합니다.

DeleteSFTP

SFTP 서버에 있는 파일을 삭제합니다.

DeleteSQS

Amazon Simple Queuing Service 큐에서 메시지를 삭제합니다

Snowflake

DeleteUnityCatalogResource

Unity Catalog 파일 또는 디렉터리를 삭제합니다.

Snowflake

DescribeDataShare

Salesforce 데이터 클라우드에서 지정된 데이터 공유 메타데이터를 설명합니다.

Snowflake

DescribeSFDCObject

Salesforce에서 지정된 오브젝트 메타데이터를 설명합니다.

DetectDuplicate

수신 각 FlowFile 에 대해 FlowFile 특성에서 계산된 값을 캐시하고 캐시된 값이 이미 표시되었는지 확인합니다.

DistributeLoad

Distribution Strategy에 따라 FlowFiles 을 다운스트림 프로세서에 배포합니다.

DuplicateFlowFile

로딩 테스트를 위해 이 프로세서는 각 수신 FlowFile 의 구성된 복사본 수를 생성합니다.

E

프로세서

설명

EncodeContent

Base64, Base32 또는 16진수 인코딩 체계를 사용하여 FlowFile 의 내용을 인코딩 또는 디코딩합니다

EncryptContentAge

수명 암호화를 사용하여 내용을 암호화합니다.

EncryptContentPGP

OpenPGP 를 사용하여 내용을 암호화합니다.

EnforceOrder

단일 노드 내에서 동일한 데이터 그룹에 속하는 FlowFiles 의 예상 순서를 적용합니다.

Snowflake

EnrichAttributes

구성된 조회 서비스를 사용하여 값을 조회하고 그 결과를 FlowFile 에 1개 이상의 특성으로 추가합니다.

Snowflake

EnrichCdcStream

CaptureChangePostgreSQL 등에서 수신 FlowFiles 을 보강합니다.

EvaluateJsonPath

FlowFile 의 내용에 대해 1개 이상의 JsonPath 식을 평가합니다.

Snowflake

EvaluateRagAnswerCorrectness

F1 점수, 코사인 유사도 및 답변 정확도와 같은 메트릭을 계산하여 검색 증강 생성(RAG) 컨텍스트에서 생성된 답변의 정확성을 평가합니다.

Snowflake

EvaluateRagFaithfulness

검색 증강 생성(RAG) 시스템에서 생성된 답변의 충실도를 LLM 을 사용해 답변을 분석하여 평가합니다.

Snowflake

EvaluateRagRetrieval

LLM 을 판단 기준으로 사용하여 RAG 시스템에 대한 검색 메트릭(Precision@N, Recall@N, FScore@N, MAP@N, MRR)을 계산합니다.

EvaluateXPath

FlowFile 의 내용에 대해 1개 이상의 XPaths 를 평가합니다.

EvaluateXQuery

FlowFile 의 내용에 대해 1개 이상의 XQueries 를 평가합니다.

ExecuteGroovyScript

실험적인 확장 Groovy 스크립트 프로세서.

ExecuteProcess

사용자가 지정한 운영 체제 명령을 실행하고 해당 명령의 출력을 FlowFile 에 씁니다.

ExecuteScript

실험적 - 플로우 파일과 프로세스 세션이 주어진 스크립트를 실행합니다.

ExecuteSQL

제공된 SQL select 쿼리를 실행합니다.

ExecuteSQLRecord

제공된 SQL select 쿼리를 실행합니다.

Snowflake

ExecuteSQLStatement

데이터베이스에 대해 SQL DDL 또는 DML 문을 실행합니다.

ExecuteStreamCommand

ExecuteStreamCommand 프로세서는 외부 명령과 스크립트를 NiFi 데이터 플로우에 유연하게 통합할 수 있는 방법을 제공합니다.

ExtractAvroMetadata

Avro 데이터 파일의 헤더에서 메타데이터를 추출합니다.

ExtractEmailAttachments

MIME 형식의 이메일 파일에서 첨부파일을 추출하여 개별 flowfile로 분할합니다.

ExtractEmailHeaders

플로우 파일 내용을 데이터 소스로 사용하여 RFC 호환 이메일 파일에서 헤더를 추출하여 관련 특성을 플로우 파일에 추가합니다.

ExtractGrok

FlowFile 의 내용에 대해 1개 이상의 Grok 식을 평가하여 결과를 특성으로 추가하거나 FlowFile 의 내용을 일치하는 내용의 JSON 표기법으로 바꿉니다

ExtractRecordSchema

제공된 Record Reader를 사용하여 FlowFile 에서 레코드 스키마를 추출해 ‘avro’에 씁니다.

Snowflake

ExtractSchemaColumns

제공된 Record Reader를 사용하여 FlowFile 에서 레코드 스키마 열을 추출하여’스키마’에 씁니다.

ExtractStructuredBoxFileMetadata

Box AI 를 사용하여 Box 파일에서 메타데이터를 추출합니다.

ExtractText

FlowFile 의 내용에 대해 1개 이상의 정규식을 평가합니다.

F

프로세서

설명

FetchAzureBlobStorage_v12

Azure Blob Storage에서 지정된 Blob을 검색하고 해당 내용을 FlowFile 의 내용에 씁니다.

FetchAzureDataLakeStorage

Azure Data Lake Storage에서 지정된 파일 가져오기

FetchBoxFile

박스 폴더에서 파일을 가져옵니다.

FetchBoxFileInfo

Box에서 파일에 대한 메타데이터를 가져와 FlowFile 의 특성에 추가합니다.

FetchBoxFileMetadataInstance

템플릿 키와 범위를 사용하여 Box 파일과 연결된 특정 메타데이터 인스턴스를 검색합니다.

FetchBoxFileRepresentation

표현 힌트를 사용하여 Box 파일 표현을 가져와 FlowFile 내용에 씁니다.

FetchDistributedMapCache

각 수신 FlowFile 에 대해 FlowFile 특성에서 캐시 키를 계산하고 각 키와 연결된 분산 맵 캐시에서 값을 가져옵니다.

FetchDropbox

Dropbox에서 파일을 가져옵니다.

FetchFile

디스크에서 파일의 내용을 읽고 수신 FlowFile 의 내용으로 스트림합니다.

FetchFTP

원격 FTP 서버에서 파일 내용을 가져와서 수신 FlowFile 의 내용을 원격 파일의 내용으로 덮어씁니다.

FetchGCSObject

Google Cloud Bucket에서 파일을 가져옵니다.

FetchGoogleDrive

Google Drive Folder에서 파일을 가져옵니다.

Snowflake

FetchGoogleDriveFileComments

Google Drive 파일에 대한 설명과 해당 댓글을 가져옵니다.

Snowflake

FetchGoogleDriveMetadata

Google Drive 파일 메타데이터를 가져옵니다.

FetchGridFS

GridFS 버킷에서 파일 이름 또는 사용자 정의 쿼리로 1개 이상의 파일을 검색합니다.

Snowflake

FetchJiraIssues

구성 가능한 검색 옵션이 있는 REST API v3을 사용하여 Jira Cloud에서 문제를 가져옵니다.

Snowflake

FetchMicrosoftDataverseTable

Microsoft Dataverse 테이블에서 레코드 가져오기

FetchS3Object

S3 오브젝트의 내용을 가져와 FlowFile 의 내용으로 기록합니다.

FetchSFTP

원격 SFTP 서버에서 파일 내용을 가져와서 수신 FlowFile 의 내용을 원격 파일의 내용으로 덮어씁니다.

Snowflake

FetchSharepointFile

Sharepoint Drive에서 파일의 내용을 가져오고, 해당되는 경우 PDF 또는 HTML 버전의 파일을 선택적으로 다운로드합니다.

Snowflake

FetchSharepointMetadata

각 드라이브 항목에 대해 해당 메타데이터와 권한을 검색하여 FlowFile 특성으로 기록합니다.

Snowflake

FetchSlackConversationInfo

Slack 대화 정보 및 멤버 이메일 가져오기

Snowflake

FetchSlackFile

Slack에서 공유된 파일을 다운로드합니다.

Snowflake

FetchSlackMessage

단일 Slack 메시지에 대한 데이터 가져오기

FetchSmb

SMB 공유에서 파일을 가져옵니다.

Snowflake

FetchSnowflakeTableProperties

테이블에서 속성을 읽고 이를 플로우 파일 특성으로 저장합니다.

Snowflake

FetchSourceTableSchema

테이블 스키마를 가져옵니다(즉,

Snowflake

FetchTableSnapshot

데이터베이스에서 테이블의 스냅샷을 가져옵니다.

FilterAttribute

지정된 특성은 유지하고 나머지는 제거하거나 지정된 특성은 제거하고 나머지는 유지하는 방식으로 FlowFile 의 특성을 필터링합니다.

Snowflake

FindSharepointDriveItem

드라이브 ID 및 항목 경로로 SharePoint 드라이브 항목을 찾습니다.

FlattenJson

사용자에게 중첩된 JSON 문서를 간단한 키-값 페어 문서로 데이터 스큐를 수행할 수 있는 기능을 제공합니다.

ForkEnrichment

JoinEnrichment 프로세서와 함께 사용되는 이 프로세서는 JoinEnrichment 프로세서가 함수를 수행하는 데 필요한 특성을 추가하는 역할을 합니다.

ForkRecord

이 프로세서를 통해 사용자는 1개의 레코드를 여러 개의 레코드로 포크할 수 있습니다.

G

프로세서

설명

Snowflake

GenerateAnswersFromContext

대규모 언어 모델(LLM)을 사용하여 수신 레코드에 있는 각 질문에 대한 합성 답변을 생성합니다.

Snowflake

GenerateAnswersFromGroundTruth

LLM 을 사용하여 수신 레코드의 각 질문에 대한 합성 답변을 생성합니다.

GenerateFlowFile

이 프로세서는 임의의 데이터 또는 사용자 정의 내용으로 FlowFiles 을 생성합니다.

Snowflake

GenerateJSON

구성 가능한 JSON 스키마를 기반으로 임의의 필드 값을 가진 JSON 오브젝트 배치를 생성합니다.

GenerateRecord

이 프로세서는 지정된 필드에 대해 임의의 값을 갖는 레코드로 FlowFiles 을 생성합니다.

GenerateTableFetch

테이블에서 행의 ‘페이지’를 가져오는 SQL select 쿼리를 생성합니다.

GeoEnrichIP

IP 주소의 지리적 위치 정보를 조회하고 FlowFile 특성에 지리적 정보를 추가합니다.

GeoEnrichIPRecord

IP 주소의 지리적 위치 정보를 조회하고 FlowFile 특성에 지리적 정보를 추가합니다.

Snowflake

GetAmazonAdsReport

준비되면 프로세서가 Amazon Ads에서 보고서를 다운로드합니다.

GetAwsPollyJobStatus

AWS Polly 작업의 현재 상태를 검색합니다.

GetAwsTextractJobStatus

AWS Textract 작업의 현재 상태를 검색합니다.

GetAwsTranscribeJobStatus

AWS Transcribe 작업의 현재 상태를 검색합니다.

GetAwsTranslateJobStatus

AWS Translate 작업의 현재 상태를 검색합니다.

GetAzureEventHub

안정적인 체크포인트 추적 없이 Microsoft Azure Event Hubs에서 메시지를 수신합니다.

GetAzureQueueStorage_v12

Azure Queue Storage에서 메시지를 검색합니다.

GetBoxFileCollaborators

Box 파일에 있는 모든 공동 작업자를 검색하고 FlowFile 의 특성에 공동 작업 정보를 추가합니다.

GetBoxGroupMembers

Box 그룹의 멤버을 검색하고 FlowFile 특성에 세부 정보를 기록합니다.

Snowflake

GetDataShareCredentials

Salesforce 데이터 클라우드에서 지정된 데이터 공유 메타데이터를 설명합니다.

Snowflake

GetDataShareTables

Salesforce 데이터 클라우드에서 지정된 데이터 공유 메타데이터를 설명합니다.

Snowflake

GetDBFSFile

DBFS 파일을 읽습니다.

GetDynamoDB

해시 및 범위 키를 기준으로 DynamoDB 에서 문서를 검색합니다.

GetElasticsearch

공식 Elastic REST 클라이언트 라이브러리를 사용하여 _id로 Elasticsearch에서 단일 문서를 가져오는 Elasticsearch get 프로세서입니다.

GetFile

디렉터리에 있는 파일에서 FlowFiles 을 생성합니다.

GetFileResource

이 프로세서는 구성된 파일 리소스의 내용으로 FlowFiles 을 생성합니다.

GetFTP

FTP 서버에서 파일을 가져와 FlowFiles 을 생성합니다

GetGcpVisionAnnotateFilesOperationStatus

Google Vision 작업의 현재 상태를 검색합니다.

GetGcpVisionAnnotateImagesOperationStatus

Google Vision 작업의 현재 상태를 검색합니다.

Snowflake

GetGoogleAdsReport

Google Ads Reporting API 와 상호 작용할 수 있는 프로세서입니다.

Snowflake

GetGoogleGroupMembers

FlowFile 특성으로 지정된 그룹 IDs 를 쉼표로 구분한 목록으로 지정된 1개 이상 Google 그룹의 멤버를 검색합니다.

Snowflake

GetGoogleSheets

Google Sheets에서 데이터를 가져오는 작업을 담당하는 프로세서입니다.

GetHubSpot

비공개 HubSpot 애플리케이션에서 JSON 데이터를 검색합니다.

Snowflake

GetHubSpotObject

HubSpot 오브젝트와 그 연관성을 ID 또는 고유 값으로 가져옵니다.

Snowflake

GetLinkedInAdsReport

LinkedIn Reporting APIs 에서 메트릭을 다운로드하는 프로세서.

Snowflake

GetMicrosoft365GroupMembers

Microsoft365 그룹 멤버를 검색하고 변경이 발생할 때마다 FlowFile 을 전송합니다.

GetMongo

사용자 지정 쿼리로 로딩된 MongoDB 의 문서에서 FlowFiles 을 생성합니다.

GetMongoRecord

Record Writer를 사용하여 MongoDB 결과 세트를 작성하는 GetMongo 의 레코드 기반 버전입니다.

Snowflake

GetQueryJobResult

Bulk API 2를 사용하여 Salesforce에서 쿼리 작업의 결과를 가져옵니다.

Snowflake

GetQueryJobStatus

Bulk API 2를 사용하여 Salesforce에서 쿼리 작업의 상태를 가져옵니다.

GetS3ObjectMetadata

S3에서 오브젝트의 존재를 확인하고 다운로드를 시도하지 않고 메타데이터를 가져옵니다.

GetS3ObjectTags

S3에서 오브젝트의 존재를 확인하고 다운로드하지 않고 해당 태그를 가져옵니다.

GetSFTP

SFTP 서버에서 파일을 가져와 FlowFiles 을 생성합니다

Snowflake

GetSharepointSiteGroupMembers

SharePoint 사이트 그룹의 모든 멤버를 검색합니다.

GetShopify

사용자 지정 Shopify 스토어에서 오브젝트를 검색합니다.

GetSmbFile

samba 네트워크 위치에서 FlowFiles 로 파일을 읽습니다.

GetSplunk

Splunk Enterprise에서 데이터를 검색합니다.

GetSQS

Amazon Simple Queuing Service 큐에서 메시지를 가져옵니다

Snowflake

GetUnityCatalogFile

최대 5 GiB 까지 Unity Catalog 파일을 읽습니다.

Snowflake

GetUnityCatalogFileMetadata

Unity Catalog 파일 메타데이터를 확인합니다.

GetWorkdayReport

구성 가능한 Workday 보고서와 상호 작용할 수 있는 프로세서입니다.

GetZendesk

Zendesk API 에서 데이터를 점진적으로 가져옵니다.

H

프로세서

설명

HandleHttpRequest

HTTP 서버를 시작하고 HTTP 요청을 수신 대기합니다.

HandleHttpResponse

FlowFile 을 생성한 요청자에게 HTTP 응답을 보냅니다.

I

프로세서

설명

IdentifyMimeType

FlowFile 에 사용되는 MIME 유형을 식별하려고 시도합니다.

InvokeHTTP

구성 가능한 HTTP 엔드포인트와 상호 작용할 수 있는 HTTP 클라이언트 프로세서입니다.

InvokeScriptedProcessor

실험적 - 지정된 스크립트에 정의된 프로세서에 대한 스크립트 엔진을 호출합니다.

ISPEnrichIP

IP 주소에 대한 ISP 정보를 조회하고 FlowFile 특성에 정보를 추가합니다.

J

프로세서

설명

JoinEnrichment

서로 다른 2개의 FlowFiles 에서 레코드를 결합하는 것으로, 1개의 FlowFile 인 ‘원본’에는 임의의 레코드가 포함되어 있고 두 번째 FlowFile 인 ‘보강’에는 첫 번째를 보강하는 데 사용해야 하는 추가 데이터가 포함되어 있습니다.

JoltTransformJSON

FlowFile JSON 내용 또는 지정된 FlowFile JSON 특성에 Jolt 사양 목록을 적용합니다.

JoltTransformRecord

FlowFile 페이로드의 각 레코드에 JOLT 사양을 적용합니다.

JSLTTransformJSON

FlowFile JSON 페이로드에 JSLT 변환을 적용합니다.

JsonQueryElasticsearch

사용자가 Elasticsearch JSON DSL 로 작성된 쿼리(집계 포함)를 실행할 수 있는 프로세서입니다.

L

프로세서

설명

Snowflake

ListArchivedHubSpotData

선택한 오브젝트 타입에 대해 HubSpot 에서 아카이브된 데이터를 목록에 나열하고 해당 메타데이터를 FlowFile 특성으로 하여 나열된 오브젝트당 1개씩 FlowFile 을 생성합니다.

ListAzureBlobStorage_v12

Azure Blob Storage 컨테이너에 있는 Blob을 목록으로 표시합니다.

ListAzureDataLakeStorage

Azure Data Lake Storage Gen 2 파일 시스템의 디렉터리 목록 표시

ListBoxFile

Box 폴더에 있는 파일을 목록으로 표시합니다.

ListBoxFileInfo

Box 폴더의 각 파일에 대한 파일 메타데이터를 가져옵니다.

ListBoxFileMetadataInstances

Box 파일과 연결된 모든 메타데이터 인스턴스를 검색합니다.

ListBoxFileMetadataTemplates

Box 파일과 연결된 모든 메타데이터 템플릿을 검색합니다.

ListDatabaseTables

데이터베이스 연결에서 테이블에 대한 메타데이터에 해당하는 특성을 각각 포함하는 플로우 파일 세트를 생성합니다.

Snowflake

ListDBFSDirectory

DBFS 디렉터리에 파일 이름을 나열하고 파일 이름으로 FlowFile 을 새로 출력합니다.

ListDropbox

Dropbox에서 파일 목록을 검색합니다(바로 가기는 무시됨).

ListenFTP

지정된 포트에서 수신 대기하는 FTP 서버를 시작하고 수신 파일을 FlowFiles 로 변환합니다.

ListenHTTP

HTTP 서버를 시작하고 지정된 기본 경로에서 수신 요청을 FlowFiles 로 변환하기 위해 수신 대기합니다.

ListenOTLP

HTTP 또는 gRPC 를 통해 OpenTelemetry 메시지를 수집합니다.

ListenSlack

1개 이상의 Slack 대화에서 실시간 메시지 또는 Slack 명령을 검색합니다.

ListenSyslog

TCP 또는 UDP 를 통해 지정된 포트로 전송되는 Syslog 메시지를 수신 대기합니다.

ListenTCP

수신 TCP 연결을 수신 대기하고 줄 바꿈 구분자를 메시지 구분 기호로 사용하여 각 연결에서 데이터를 읽습니다.

ListenUDP

지정된 포트에서 데이터그램 패킷을 수신 대기합니다.

ListenUDPRecord

지정된 포트에서 데이터그램 패킷을 수신 대기하고 구성된 Record Reader를 사용하여 각 데이터그램의 내용을 읽습니다.

ListenWebSocket

클라이언트 연결을 수락하는 WebSocket 서버 엔드포인트 역할을 합니다.

ListFile

입력 디렉터리에서 파일 목록을 검색합니다.

ListFTP

FTP 서버에 있는 파일 목록을 수행합니다.

ListGCSBucket

GCS 버킷에서 오브젝트 목록을 검색합니다.

ListGoogleDrive

Google Drive 폴더에 있는 구체적인 파일 목록(바로 가기는 무시됨)을 수행합니다.

Snowflake

ListGoogleDriveFileInfo

지정된 Google Drive에 있는 모든 파일과 폴더를 목록으로 표시합니다.

Snowflake

ListGoogleGroups

Google Workspace에서 지정된 도메인에 대한 모든 그룹을 목록으로 표시합니다.

Snowflake

ListHubSpotObjects

지정된 오브젝트 타입에 대해 HubSpot 에서 데이터를 가져오고, 나열된 오브젝트당 1개씩 FlowFile 을 생성하며, 해당 메타데이터를 FlowFile 특성으로 추가합니다.

Snowflake

ListMicrosoftDataverseTables

Microsoft Dataverse 환경에서 테이블 목록 생성하기

ListS3

S3 버킷에서 오브젝트 목록을 검색합니다.

Snowflake

ListSFDCDataShares

식별된 사용자가 사용할 수 있는 조직에서 사용 가능한 데이터 공유를 나열합니다.

Snowflake

ListSFDCObjects

식별된 사용자가 사용할 수 있는 조직 내 사용 가능한 오브젝트를 나열합니다.

ListSFTP

SFTP 서버에 있는 파일 목록을 수행합니다.

Snowflake

ListSharepointDrives

지정된 SharePoint 사이트에 있는 각 드라이브에 대해 FlowFile 을 전송합니다.

Snowflake

ListSharepointSiteGroups

지정된 SharePoint 사이트에서 사용 가능한 모든 SharePoint 사이트 그룹을 목록으로 표시합니다.

ListSmb

SMB 프로토콜을 통해 공유된 구체적인 파일을 목록으로 표시합니다.

Snowflake

ListTableNames

모든 소스 테이블 이름을 가져와서 가능한 구성 중 하나인 - regexp expression e와 일치시킵니다.

Snowflake

ListUnityCatalogDirectory

Unity Catalog 디렉터리에서 파일 이름을 나열하고 파일 이름으로FlowFile을 새로 출력합니다.

LogAttribute

지정된 로그 수준에서 FlowFile 의 특성을 방출합니다

LogMessage

지정된 로그 수준에서 로그 메시지를 내보냅니다

LookupAttribute

조회 서비스에서 특성 조회하기

LookupRecord

레코드에서 1개 이상의 필드를 추출하고 LookupService 에서 해당 필드에 대한 값을 조회합니다.

M

프로세서

설명

MergeContent

사용자 정의 전략에 따라 FlowFiles 그룹을 병합하여 단일 FlowFile 로 패키지화합니다.

MergeRecord

이 프로세서는 여러 개의 레코드 지향 FlowFiles 을 입력된 FlowFiles 의 모든 레코드를 포함하는 단일 FlowFile 로 병합합니다.

Snowflake

MergeSnowflakeJournalTable

저널 테이블에서 대상 테이블로의 변경 사항에 대해 Snowflake에서 병합 작업을 트리거합니다.

ModifyBytes

이진 파일의 시작과 끝 또는 모든 내용의 바이트 범위를 삭제합니다.

ModifyCompression

사용자가 지정한 압축 알고리즘을 사용하여 FlowFiles 의 내용을 압축 해제하고 지정된 압축 형식 속성을 사용하여 내용을 다시 압축하여 FlowFile 의 내용을 압축하는 데 사용되는 압축 알고리즘을 변경합니다.

MonitorActivity

플로우의 활동을 모니터링하고 플로우에 지정된 시간 동안 데이터가 없는 경우 표시기를 보내고 플로우의 활동이 복원되면 다시 표시기를 보냅니다

MoveAzureDataLakeStorage

Azure Data Lake Storage Gen 2 내에서 내용을 이동합니다.

N

프로세서

설명

알림

선택적으로 FlowFile 의 특성과 함께 릴리스 신호 식별자를 분산 캐시에 캐시합니다.

O

프로세서

설명

Snowflake

OpenAiTranscribeAudio

오디오를 영어 텍스트로 변환합니다.

P

프로세서

설명

PackageFlowFile

이 프로세서는 FlowFile 특성과 내용을 NiFi 에서 내보내고 NiFi 로 다시 가져올 수 있는 출력 FlowFile 로 패키지화하여 원래 특성과 내용을 보존합니다.

PaginatedJsonQueryElasticsearch

사용자가 Elasticsearch JSON DSL 로 작성된 페이지 매김 쿼리(집계 포함)를 실행할 수 있는 프로세서입니다.

ParseEvtx

Windows Event Log 파일(evtx)의 내용을 구문 분석하고 그 결과 XML 을 FlowFile 에 씁니다.

Snowflake

ParseExcelCellReference

Excel 셀 참조 수식 구문 분석을 담당하는 프로세서입니다.

ParseSyslog

RFC5424 및 RFC3164 형식에 따라 Syslog 메시지의 내용을 구문 분석하고 Syslog 메시지의 각 부분에 대해 FlowFile 에 특성을 추가하려고 시도합니다.

ParseSyslog5424

잘 구성된 Syslog 메시지의 내용을 RFC5424 형식에 따라 구문 분석을 시도하고 정형 데이터를 포함한 Syslog 메시지의 각 부분에 대해 FlowFile 에 특성을 추가합니다.

PartitionRecord

데이터에 구성된 필드를 기반으로 레코드 중심의 데이터를 분할 또는 파티션합니다.

Snowflake

PerformSnowflakeCortexOCR

Snowflake Cortex ML 함수를 사용하여 PDF 문서에서 광학 문자 인식(OCR)을 수행합니다.

Snowflake

PickTablesForReplication

정규화된 테이블 이름 목록을 받아 테이블이 - 신규(복제되지 않았지만 소스에 추가됨) - 기존(복제되었고 소스에 존재함) - 부실(복제되었지만 소스에 더 이상 존재하지 않음)인지를 결정합니다. 구성은 FlowFile 특성으로 전달됩니다.

Snowflake

PromptAnthropicAI

응답을 FlowFile 특성으로 작성하거나 수신 FlowFile 의 내용으로 작성하여 Anthropic에 프롬프트를 보냅니다.

Snowflake

PromptAzureOpenAI

응답을 FlowFile 특성 또는 수신 FlowFile 의 내용으로 작성하여 Azure의 OpenAI 서비스로 프롬프트를 보냅니다.

Snowflake

PromptLLM

이 프로세서는 사용자 정의 프롬프트를 대규모 언어 모델(LLM)로 전송하여 응답합니다.

Snowflake

PromptOpenAI

FlowFile 특성 또는 수신 FlowFile 의 내용으로 응답을 작성하여 OpenAI 로 프롬프트를 보냅니다.

Snowflake

PromptSnowflakeCortex

응답을 FlowFile 특성 또는 수신 FlowFile 의 내용으로 작성하여 Snowflake Cortex에 프롬프트를 보냅니다.

Snowflake

PromptVertexAI

FlowFile 특성 또는 수신 FlowFile 의 내용으로 응답을 작성하여 VertexAI 로 프롬프트를 보냅니다.

PublishAMQP

FlowFile 의 내용으로 AMQP 메시지를 생성하고 AMQP Exchange로 메시지를 보냅니다.

PublishGCPubSub

수신 flowfile의 내용을 구성된 Google Cloud PubSub 토픽에 게시합니다.

PublishJMS

FlowFile 의 내용으로 JMS 메시지를 생성하고 JMS BytesMessage 또는 TextMessage 로 JMS 대상(큐 또는 항목)으로 보냅니다.

PublishKafka

FlowFile 의 내용을 메시지 또는 개별 레코드로서 Kafka Producer API 를 사용하여 Apache Kafka로 전송합니다.

Snowflake

PublishKafka

FlowFile 의 내용을 메시지 또는 개별 레코드로서 Kafka Producer API 를 사용하여 Apache Kafka로 전송합니다.

PublishMQTT

MQTT 항목에 메시지를 게시합니다

PublishSlack

지정된 Slack 채널에 메시지를 게시합니다.

PutAzureBlobStorage_v12

내용을 Azure Blob Storage의 Blob에 넣습니다.

PutAzureCosmosDBRecord

이 프로세서는 Core SQL API 를 사용하여 Cosmos DB 에 데이터를 삽입하기 위한 레코드 인식 프로세서입니다.

PutAzureDataExplorer

제공된 엔드포인트로 FlowFiles 을 전송하는 Azure 데이터 탐색기 싱크 역할을 합니다.

PutAzureDataLakeStorage

FlowFile 의 내용을 Azure Data Lake Storage Gen 2에 파일로 씁니다

PutAzureEventHub

FlowFile 내용을 Azure Event Hubs로 보내기

PutAzureQueueStorage_v12

수신 FlowFiles 의 내용을 구성된 Azure Queue Storage에 씁니다.

PutBigQuery

FlowFile 의 내용을 Google BigQuery 테이블에 씁니다.

PutBoxFile

Box 폴더에 내용을 넣습니다.

PutCloudWatchMetric

Amazon CloudWatch 에 메트릭을 게시합니다.

PutDatabaseRecord

PutDatabaseRecord 프로세서는 지정된 RecordReader 를 사용하여 수신 플로우 파일에서 (여러 개일 수 있는) 레코드를 입력합니다.

Snowflake

PutDatabricksSQL

Databricks REST API 를 사용하여 SQL 실행을 제출한 다음 JSON 응답을 FlowFile 내용에 작성합니다.

Snowflake

PutDBFSFile

FlowFile 내용을 DBFS 로 작성합니다.

PutDistributedMapCache

FlowFile 특성에서 계산된 캐시 키를 사용하여 FlowFile 의 내용을 가져와 분산 맵 캐시에 저장합니다.

PutDropbox

Dropbox 폴더에 내용을 넣습니다.

PutDynamoDB

해시 및 범위 키에 따라 DynamoDB 의 문서를 넣습니다.

PutDynamoDBRecord

레코드 지향 데이터를 기반으로 DynamoDB 에 항목을 삽입합니다.

PutElasticsearchJson

공식 Elastic REST 클라이언트 라이브러리를 사용하는 Elasticsearch 풋 프로세서입니다.

PutElasticsearchRecord

공식 Elastic REST 클라이언트 라이브러리를 사용하는 레코드 인식 Elasticsearch put 프로세서입니다.

PutEmail

각 수신 FlowFile 에 대해 구성된 수신자에게 이메일을 보냅니다

PutFile

FlowFile 의 내용을 로컬 파일 시스템에 씁니다

PutFTP

FlowFiles 을 FTP 서버로 전송합니다

PutGCSObject

FlowFile 의 내용을 Google Cloud Storage에 오브젝트로 씁니다.

PutGoogleDrive

FlowFile 의 내용을 Google Drive에 파일로 씁니다.

PutGridFS

GridFS 버킷에 파일을 씁니다.

Snowflake

PutHubSpot

HubSpot 오브젝트를 업서트합니다.

Snowflake

PutIcebergTable

네임스페이스와 테이블을 관리하기 위해 구성 가능한 카탈로그를 사용하여 Iceberg에 레코드를 저장합니다.

PutKinesisFirehose

지정된 Amazon Kinesis Firehose로 내용을 전송합니다.

PutKinesisStream

지정된 Amazon Kinesis로 내용을 전송합니다.

PutLambda

내용을 지정된 Amazon Lambda 함수로 보냅니다.

PutMongo

FlowFile의 내용을 MongoDB 로 씁니다

PutMongoBulkOperations

FlowFile 의 내용을 MongoDB 에 일괄 업데이트로 씁니다

PutMongoRecord

이 프로세서는 MongoDB 에 데이터를 삽입/업서트하기 위한 레코드 인식 프로세서입니다.

PutRecord

PutRecord 프로세서는 지정된 RecordReader 를 사용하여 수신 플로우 파일에서 (여러 개일 수 있는) 레코드를 입력한 후 레코드 대상 서비스에서 지정한 대상으로 전송합니다.

PutRedisHashRecord

해시 값이 포함된 각 레코드의 필드에 RecordPath 에 의해 결정되는 지정된 해시 값을 사용하여 레코드 필드 데이터를 Redis에 넣습니다.

PutS3Object

FlowFile 의 내용을 Amazon S3 버킷에 S3 오브젝트로 씁니다.

PutSalesforceObject

지정된 Salesforce sObject에 대한 새 레코드를 생성합니다.

PutSFTP

FlowFiles 을 SFTP 서버로 전송합니다

PutSmbFile

FlowFile 의 내용을 samba 네트워크 위치에 씁니다.

Snowflake

PutSnowflakeInternalStageFile

파일을 Snowflake 내부 스테이지에 넣습니다.

Snowflake

PutSnowpipeStreaming

레코드를 Snowflake 테이블로 스트림합니다.

PutSNS

FlowFile 의 내용을 Amazon 간편 알림 서비스에 알림으로 보냅니다

PutSplunk

TCP, TCP + TLS/SSL 또는 UDP 를 통해 로그를 Splunk Enterprise로 전송합니다.

PutSplunkHTTP

HTTP 또는 HTTPS 를 통해 지정된 Splunk 서버로 플로우 파일 내용을 전송합니다.

PutSQL

SQL UPDATE 또는 INSERT 명령을 실행합니다.

PutSQS

Amazon Simple Queuing Service 큐에 메시지를 게시합니다

PutSyslog

TCP 또는 UDP 를 통해 지정된 호스트와 포트로 Syslog 메시지를 전송합니다.

PutTCP

직렬화된 FlowFiles 또는 레코드를 TCP 를 통해 구성 가능한 대상으로 전송하며, TLS 를 옵션으로 지원합니다.

PutUDP

PutUDP 프로세서는 FlowFile 을 수신하고 FlowFile 내용을 단일 UDP 데이터그램 패킷으로 패키징한 다음 구성된 UDP 서버로 전송합니다.

Snowflake

PutUnityCatalogFile

Unity Catalog에 최대 5 GiB 크기의 FlowFile 내용을 작성합니다.

Snowflake

PutVectaraDocument

JSON 문서를 생성하여 Vectara의 업로드 엔드포인트에 업로드합니다.

Snowflake

PutVectaraFile

FlowFile 내용을 Vectara의 인덱스 엔드포인트에 업로드합니다.

PutWebSocket

ListenWebSocket 또는 ConnectWebSocket 에서 설정한 WebSocket 세션을 사용하여 WebSocket 원격 엔드포인트로 메시지를 보냅니다.

PutZendeskTicket

Zendesk API 를 사용하여 Zendesk 티켓을 생성합니다.

Q

프로세서

설명

QueryAzureDataExplorer

Azure 데이터 탐색기를 쿼리하고 JSON 결과를 출력 FlowFiles 로 스트리밍합니다.

QueryDatabaseTable

SQL select 쿼리를 생성하거나 제공된 문을 사용하여 실행하여 지정된 최대값 열의 값이 이전에 표시된 최대값보다 큰 모든 행을 가져옵니다.

QueryDatabaseTableRecord

SQL select 쿼리를 생성하거나 제공된 문을 사용하여 실행하여 지정된 최대값 열의 값이 이전에 표시된 최대값보다 큰 모든 행을 가져옵니다.

Snowflake

QueryMilvus

벡터를 사용하여 Milvus 데이터베이스에서 지정된 컬렉션을 쿼리합니다.

Snowflake

QueryPinecone

입력 벡터와 유사한 벡터를 Pinecone에 쿼리하거나 ID 로 벡터를 검색합니다.

QueryRecord

FlowFile 의 내용에 대해 1개 이상의 SQL 쿼리를 평가합니다.

QuerySalesforceObject

Salesforce sObject에서 레코드를 검색합니다.

QuerySplunkIndexingStatus

인덱스 승인 상태를 얻기 위해 Splunk 서버에 쿼리합니다.

R

프로세서

설명

RemoveRecordField

레코드 지향 데이터를 포함하는 FlowFile 의 내용을 수정했습니다.

RenameRecordField

FlowFile 의 각 레코드에서 1개 이상의 필드 이름을 바꿉니다.

ReplaceText

FlowFile 내용에서 일부 텍스트 값(정규식/regex 또는 리터럴 값)을 검색하고 일치하는 내용 섹션을 일부 대체 값으로 대체하여 FlowFile 의 내용을 업데이트합니다.

ReplaceTextWithMapping

정규식을 기준으로 평가하고 정규식과 일치하는 내용 섹션을 매핑 파일에 제공된 대체 값으로 대체하여 FlowFile 의 내용을 업데이트합니다.

RetryFlowFile

이 프로세서로 전달된 FlowFiles 에는 구성된 ‘최대 재시도 횟수’ 값에 대해 ‘재시도 특성’ 값이 선택되어 있습니다.

RouteOnAttribute

특성 표현식 언어를 사용하여 특성에 따라 FlowFiles 을 라우팅합니다.

RouteOnContent

FlowFile 의 내용에 정규식을 적용하고 정규식이 일치하는 각 대상에 FlowFile 의 복사본을 라우팅합니다.

RouteText

사용자가 정의한 규칙 세트를 기반으로 텍스트 데이터를 라우팅합니다.

Snowflake

RunDatabricksJob

사용자 정의 매개 변수를 사용하여 미리 정의된 Databricks 작업이 실행되도록 트리거합니다.

RunMongoAggregation

flowfile이 수신될 때마다 집계 쿼리를 실행하는 프로세서입니다.

S

프로세서

설명

SampleRecord

지정된 Sampling Strategy(예: 저장소 샘플링)에 따라 FlowFile 의 레코드를 샘플링합니다.

ScanAttribute

FlowFiles 의 지정된 특성을 스캔하여 지정된 용어 사전 내에 해당 값이 있는지 확인합니다

ScanContent

FlowFiles 의 내용을 스캔하여 사용자가 제공한 사전에서 찾은 용어를 검색합니다.

ScriptedFilterRecord

이 프로세서는 사용자가 제공한 스크립트를 사용하여 FlowFiles 에서 레코드를 필터링하는 기능을 제공합니다.

ScriptedPartitionRecord

레코드 지향 데이터를 수신합니다(즉,

ScriptedTransformRecord

수신 FlowFile 의 각 레코드에 대해 간단한 스크립트를 평가하는 기능을 제공합니다.

ScriptedValidateRecord

이 프로세서는 사용자가 제공한 스크립트를 사용하여 FlowFiles 에서 레코드의 유효성을 검사하는 기능을 제공합니다.

SearchElasticsearch

사용자가 Elasticsearch JSON DSL 로 작성된 페이지 매김 쿼리(집계 포함)를 반복적으로 실행할 수 있는 프로세서입니다.

SegmentContent

FlowFile 을 바이트 경계에서 여러 개의 작은 세그먼트로 분할합니다.

SignContentPGP

OpenPGP 개인 키를 사용하여 내용에 서명합니다.

Snowflake

SnowflakeDetectDuplicate

FlowFile 의 해시(FlowFile특성으로 제공됨)가 이미 Snowflake 테이블에 있는지 확인하고, 발견되면 FlowFile 을 ‘중복’, 발견되지 않으면 ‘고유’, 오류 시 ‘실패’로 라우팅합니다.

SplitAvro

이진 인코딩된 Avro 데이터 파일을 구성된 출력 크기에 따라 더 작은 파일로 분할합니다.

SplitContent

수신 FlowFiles 을 지정된 바이트 시퀀스로 분할합니다

SplitExcel

이 프로세서는 여러 장의 Microsoft Excel 스프레드시트를 여러 개의 Microsoft Excel 스프레드시트로 분할하여 원본 파일의 각 시트를 자체 플로우 파일에 있는 개별 스프레드시트로 변환합니다.

SplitJson

JSON 파일을 JsonPath 식에 지정된 배열 요소에 대해 별도의 FlowFiles 파일 여러 개로 분할합니다.

SplitRecord

레코드 지향 데이터 형식의 입력 FlowFile 을 여러 개의 작은 FlowFiles 로 분할합니다.

SplitText

최대 줄 수 또는 조각의 총 크기로 제한되는 줄 경계에서 텍스트 파일을 여러 개의 작은 텍스트 파일로 분할합니다.

SplitXml

XML 파일을 각각 원래 루트 요소의 하위 또는 하위 요소로 구성된 여러 개의 개별 FlowFiles 로 분할합니다

StartAwsPollyJob

AWS Polly 작업을 트리거합니다.

StartAwsTextractJob

AWS Textract 작업을 트리거합니다.

StartAwsTranscribeJob

AWS Transcribe 작업을 트리거합니다.

StartAwsTranslateJob

AWS Translate 작업을 트리거합니다.

StartGcpVisionAnnotateFilesOperation

파일 입력 시 비전 작업을 트리거합니다.

StartGcpVisionAnnotateImagesOperation

이미지 입력 시 비전 작업을 트리거합니다.

Snowflake

SubmitQueryJob

Bulk API 2를 사용하여 Salesforce로 쿼리 작업을 제출합니다.

Snowflake

SummarizeText

이 프로세서는 대규모 언어 모델(LLM)을 사용하여 FlowFile 의 내용을 요약합니다.

T

프로세서

설명

TagS3Object

Amazon S3 오브젝트에 태그를 추가하거나 업데이트합니다.

TailFile

파일 또는 파일 목록을 ‘테일링’하여 파일에 기록될 때 파일에서 데이터를 수집합니다.

TransformXml

제공된 XSLT 파일을 FlowFile XML 페이로드에 적용합니다.

U

프로세서

설명

UnpackContent

여러 가지 패키지 형식 중 하나로 패키징된 FlowFiles 의 내용을 언패킹하여 각 입력 FlowFile 에 대해 하나에서 여러 개의 FlowFiles 을 전송합니다.

UpdateAttribute

특성 표현식 언어를 사용하여 FlowFile 의 특성을 업데이트하거나 정규식을 기반으로 특성을 삭제합니다

UpdateBoxFileMetadataInstance

지정된 flowfile의 레코드를 사용하여 Box 파일의 메타데이터 템플릿 값을 업데이트합니다.

UpdateByQueryElasticsearch

쿼리를 사용해 Elasticsearch 인덱스에서 문서를 업데이트합니다.

UpdateCounter

이 프로세서를 통해 사용자는 플로우에서 특정 카운터와 키 포인트를 설정할 수 있습니다.

UpdateDatabaseTable

이 프로세서는 JDBC 연결과 수신 레코드를 사용하여 수신 레코드를 지원하는 데 필요한 데이터베이스 테이블 변경 사항을 생성합니다.

UpdateRecord

레코드 지향 데이터를 포함하는 FlowFile 의 내용을 업데이트합니다.

Snowflake

UpdateSnowflakeDatabase

수신 FlowFile 에 제공된 스키마를 기반으로 Snowflake 테이블의 정의를 업데이트합니다.

Snowflake

UpdateSnowflakeIcebergDatabase

Snowflake Iceberg 테이블의 정의를 업데이트합니다.

Snowflake

UpdateTableState

테이블 상태 서비스에서 테이블의 상태를 업데이트합니다

Snowflake

UpsertMilvus

주어진 컬렉션에 대해 Milvus 데이터베이스에 벡터를 업서트합니다

Snowflake

UpsertPinecone

메타데이터를 포함한 벡터와 선택적으로 텍스트를 Pinecone 인덱스에 게시합니다.

Snowflake

UpsertSFDCObjects

수신 FlowFile 의 레코드를 Salesforce에 업서트합니다

V

프로세서

설명

ValidateCsv

FlowFiles 또는 FlowFile 특성 값의 내용을 사용자가 지정한CSV스키마와 비교하여 유효성을 검사합니다.

ValidateJson

구성 가능한 JSON 스키마에 대해 FlowFiles 의 내용을 검증합니다.

ValidateRecord

수신되는FlowFile의 레코드를 주어진 스키마와 비교하여 유효성을 검사합니다.

ValidateXml

FlowFile 에 포함된 XML 의 유효성을 검사합니다.

VerifyContentMAC

제공된 시크릿 키를 사용하여 메시지 인증 코드를 계산하고 제공된 MAC 속성과 비교합니다

VerifyContentPGP

OpenPGP 공개 키를 사용하여 서명을 확인합니다

W

프로세서

설명

대기

해당 Notify 프로세서에서 일치하는 릴리스 신호가 분산 캐시에 저장될 때까지 수신 FlowFiles 을 ‘대기’ 관계로 라우팅합니다.

Snowflake

WaitForTableState

해당 테이블 상태가 허용 상태와 같지 않을 때까지 수신 FlowFiles 을 차단합니다.