모든 프로세서(알파벳순)¶
이 항목에서는 알파벳 순서대로 모든 Snowflake openflow 프로세서 목록을 제공합니다. 이 목록은 다음을 포함합니다.
각 프로세서의 이름
각 프로세서에 대한 요약
A¶
프로세서 |
설명 |
|
---|---|---|
Snowflake |
Bulk API 2를 사용하여 Salesforce에서 쿼리 작업을 중단합니다. |
|
입력 FlowFile 특성의 CSV 표현을 생성합니다. |
||
입력 FlowFile 특성의 JSON 표현을 생성합니다. |
C¶
프로세서 |
설명 |
|
---|---|---|
레코드 세트의 레코드 수를 계산하며, 선택적으로 카테고리별 요소 수를 계산합니다(여기서 카테고리는 사용자 정의 속성에 의해 정의됨). |
||
Snowflake |
MySQL 데이터베이스에서 CDC 이벤트를 읽습니다. |
|
Snowflake |
PostgreSQL 데이터베이스에서 CDC 이벤트를 읽습니다. |
|
Snowflake |
SQL 서버 데이터베이스에서 CDC 이벤트를 읽습니다. |
|
Snowflake |
Shared Google Drive의 변경 내용을 캡처하고 변경 사항이 발생할 때마다 FlowFile 을 전송합니다. |
|
Snowflake |
Microsoft 365 그룹의 변경 사항을 감지하고 각 변경 사항에 대해 FlowFile 을 전송합니다. |
|
Snowflake |
SharePoint 문서 라이브러리에서 변경 내용을 캡처하고 변경이 발생할 때마다 FlowFile 을 전송합니다. |
|
Snowflake |
프로세서가 Meta Ads 보고서를 다운로드할 준비가 되었는지 확인합니다. |
|
Snowflake |
구분 기호 및 최대 문자 길이로 재귀적으로 분할하는 옵션이 있는 청크 텍스트입니다. |
|
Snowflake |
구분 기호 및 최대 문자 길이로 재귀적으로 분할하는 옵션이 있는 청크 텍스트입니다. |
|
사용자가 지정한 압축 알고리즘을 사용하여 FlowFiles 의 내용을 압축 또는 압축 해제하고 MIME을 업데이트합니다. |
||
원격 WebSocket 서버와 상호 작용하는 WebSocket 클라이언트 엔드포인트의 역할을 합니다. |
||
AMQP 0을 사용하여 AMQP 브로커의 AMQP 메시지를 소비합니다. |
||
일관된 이벤트 처리를 보장하기 위해 체크포인팅을 통해 Microsoft Azure Event Hubs에서 메시지를 수신합니다. |
||
Box admin_logs_streaming 스트림 유형에서 엔터프라이즈 이벤트를 소비합니다. |
||
Box의 모든 이벤트를 소비합니다. |
||
범위 쿼리를 사용하여 필드에 대해 페이지 매김된 쿼리를 반복적으로 실행하여 Elasticsearch 인덱스/쿼리에서 새 문서를 소비하는 프로세서입니다. |
||
구성된 Google Cloud PubSub 구독의 메시지를 소비합니다. |
||
IMAP 프로토콜을 사용하여 이메일 서버에서 메시지를 소비합니다. |
||
BytesMessage, TextMessage, ObjectMessage, MapMessage 또는 StreamMessage 유형의 JMS 메시지를 소비하여 그 내용을 FlowFile 로 변환하고 ‘성공’ 관계로 전환합니다. |
||
Apache Kafka Consumer API 의 메시지를 소비합니다. |
||
Snowflake |
Apache Kafka Consumer API 의 메시지를 소비합니다. |
|
지정된 AWS Kinesis Stream에서 데이터를 읽고 처리된 모든 레코드(원시)에 대해 FlowFile, Record Reader와 Record Writer가 구성된 경우 처리된 레코드 배치에 대해 FlowFile 을 출력합니다. |
||
항목을 구독하고 MQTT브 로커로부터 메시지를 수신합니다 |
||
POP3 프로토콜을 사용하여 이메일 서버에서 메시지를 소비합니다. |
||
구성된 1개 이상의 Slack 채널에서 메시지를 검색합니다. |
||
Snowflake |
앱에서 사용 가능한 Slack 대화에서 메시지를 검색합니다. |
|
Snowflake |
앱에서 사용 가능한 모든 Slack 채널에서 과거 메시지를 가져옵니다. |
|
Snowflake |
Snowflake 스트림에서 데이터를 가져와 FlowFile 에 씁니다. |
|
Twitter의 스트림 API v2에서 트윗을 스트리밍합니다. |
||
후속 프로세서로 데이터를 전송하는 속도를 제어합니다. |
||
FlowFile 의 내용을 한 문자 세트에서 다른 문자 세트로 변환합니다 |
||
구성된 Record Reader 및 레코드 쓰기 컨트롤러 서비스를 사용하여 한 데이터 형식에서 다른 데이터 형식으로 레코드를 변환합니다. |
||
Snowflake |
수신 데이터베이스 스키마를 Snowflake CDC Journal 테이블에 적합한 스키마로 변환합니다. |
|
한 계정/컨테이너에서 다른 계정/컨테이너로 Azure Blob Storage의 Blob을 복사본으로 복사합니다. |
||
AWS S3에서 한 버킷과 키에서 다른 버킷과 키로 파일 복사본 만들기 |
||
수신 텍스트에 대한 다양한 메트릭을 계산합니다. |
||
Snowflake |
Amazon Ads 커넥터에 대한 보고서 구성을 생성하는 프로세서입니다. |
|
Snowflake |
Azure OpenAI 를 사용하여 텍스트용 임베딩을 생성합니다. |
|
flowfile 내용의 값으로 지정된 템플릿을 사용하여 Box 파일에 대한 메타데이터 인스턴스를 생성합니다. |
||
flowFile 내용의 필드 사양을 사용하여 Box 메타데이터 템플릿을 생성합니다. |
||
Snowflake |
Cohere를 사용하여 텍스트 임베딩을 생성합니다. |
|
Snowflake |
Meta Ads 커넥터에 대한 보고서 구성을 생성하는 프로세서입니다. |
|
Snowflake |
OpenAI 를 사용하여 텍스트용 임베딩을 생성합니다. |
|
Snowflake |
Snowflake Cortex Large Language Model 함수를 사용하여 벡터 임베딩 생성하기 |
|
Snowflake |
VertexAI 를 사용하여 텍스트용 임베딩을 생성합니다. |
|
주어진 알고리즘을 사용하여 flowfile 내용에 대한 암호화 해시값을 계산하고 출력 특성에 기록합니다. |
D¶
프로세서 |
설명 |
|
---|---|---|
DebugFlow 프로세서는 타이머 또는 cron 기반 스케줄링을 사용하는 경우 FlowFile 없이 FlowFile 또는 타이머 이벤트 수신에 대해 다양한 응답을 명시적으로 트리거할 수 있도록 하여 FlowFile 프레임워크의 테스트 및 디버깅을 지원합니다. |
||
수명 암호화를 사용하여 내용을 해독합니다. |
||
OpenPGP 메시지의 내용을 해독합니다. |
||
이 프로세서는 레코드 세트 내의 개별 레코드의 중복을 제거합니다. |
||
지정된 Blob을 Azure Blob Storage에서 삭제합니다. |
||
제공된 파일을 Azure Data Lake Storage에서 삭제합니다 |
||
지정된 템플릿 키를 사용하여 Box 파일에서 메타데이터 인스턴스를 삭제합니다 |
||
쿼리를 사용하여 Elasticsearch 인덱스에서 삭제합니다. |
||
Snowflake |
DBFS 파일 및 디렉터리를 삭제합니다. |
|
해시 및 범위 키에 따라 DynamoDB 에서 문서를 삭제합니다. |
||
파일 시스템에서 파일을 삭제합니다. |
||
Google Cloud Bucket에서 오브젝트를 삭제합니다. |
||
파일 이름 또는 쿼리를 사용하여 GridFS 에서 파일을 삭제합니다. |
||
Snowflake |
Milvus 데이터베이스에서 ID 에 의해 컬렉션에서 벡터를 삭제합니다. |
|
MongoDB 컬렉션에 대해 삭제 쿼리를 실행합니다. |
||
Snowflake |
Pinecone 인덱스에서 벡터를 삭제합니다. |
|
Snowflake |
Bulk API 2를 사용하여 Salesforce에서 쿼리 작업을 삭제합니다. |
|
Amazon S3 버킷에서 파일을 삭제합니다. |
||
SFTP 서버에 있는 파일을 삭제합니다. |
||
Amazon Simple Queuing Service 큐에서 메시지를 삭제합니다 |
||
Snowflake |
Unity Catalog 파일 또는 디렉터리를 삭제합니다. |
|
Snowflake |
Salesforce 데이터 클라우드에서 지정된 데이터 공유 메타데이터를 설명합니다. |
|
Snowflake |
Salesforce에서 지정된 오브젝트 메타데이터를 설명합니다. |
|
수신 각 FlowFile 에 대해 FlowFile 특성에서 계산된 값을 캐시하고 캐시된 값이 이미 표시되었는지 확인합니다. |
||
Distribution Strategy에 따라 FlowFiles 을 다운스트림 프로세서에 배포합니다. |
||
로딩 테스트를 위해 이 프로세서는 각 수신 FlowFile 의 구성된 복사본 수를 생성합니다. |
E¶
프로세서 |
설명 |
|
---|---|---|
Base64, Base32 또는 16진수 인코딩 체계를 사용하여 FlowFile 의 내용을 인코딩 또는 디코딩합니다 |
||
수명 암호화를 사용하여 내용을 암호화합니다. |
||
OpenPGP 를 사용하여 내용을 암호화합니다. |
||
단일 노드 내에서 동일한 데이터 그룹에 속하는 FlowFiles 의 예상 순서를 적용합니다. |
||
Snowflake |
구성된 조회 서비스를 사용하여 값을 조회하고 그 결과를 FlowFile 에 1개 이상의 특성으로 추가합니다. |
|
Snowflake |
CaptureChangePostgreSQL 등에서 수신 FlowFiles 을 보강합니다. |
|
FlowFile 의 내용에 대해 1개 이상의 JsonPath 식을 평가합니다. |
||
Snowflake |
F1 점수, 코사인 유사도 및 답변 정확도와 같은 메트릭을 계산하여 검색 증강 생성(RAG) 컨텍스트에서 생성된 답변의 정확성을 평가합니다. |
|
Snowflake |
검색 증강 생성(RAG) 시스템에서 생성된 답변의 충실도를 LLM 을 사용해 답변을 분석하여 평가합니다. |
|
Snowflake |
LLM 을 판단 기준으로 사용하여 RAG 시스템에 대한 검색 메트릭(Precision@N, Recall@N, FScore@N, MAP@N, MRR)을 계산합니다. |
|
FlowFile 의 내용에 대해 1개 이상의 XPaths 를 평가합니다. |
||
FlowFile 의 내용에 대해 1개 이상의 XQueries 를 평가합니다. |
||
실험적인 확장 Groovy 스크립트 프로세서. |
||
사용자가 지정한 운영 체제 명령을 실행하고 해당 명령의 출력을 FlowFile 에 씁니다. |
||
실험적 - 플로우 파일과 프로세스 세션이 주어진 스크립트를 실행합니다. |
||
제공된 SQL select 쿼리를 실행합니다. |
||
제공된 SQL select 쿼리를 실행합니다. |
||
Snowflake |
데이터베이스에 대해 SQL DDL 또는 DML 문을 실행합니다. |
|
ExecuteStreamCommand 프로세서는 외부 명령과 스크립트를 NiFi 데이터 플로우에 유연하게 통합할 수 있는 방법을 제공합니다. |
||
Avro 데이터 파일의 헤더에서 메타데이터를 추출합니다. |
||
MIME 형식의 이메일 파일에서 첨부파일을 추출하여 개별 flowfile로 분할합니다. |
||
플로우 파일 내용을 데이터 소스로 사용하여 RFC 호환 이메일 파일에서 헤더를 추출하여 관련 특성을 플로우 파일에 추가합니다. |
||
FlowFile 의 내용에 대해 1개 이상의 Grok 식을 평가하여 결과를 특성으로 추가하거나 FlowFile 의 내용을 일치하는 내용의 JSON 표기법으로 바꿉니다 |
||
제공된 Record Reader를 사용하여 FlowFile 에서 레코드 스키마를 추출해 ‘avro’에 씁니다. |
||
Snowflake |
제공된 Record Reader를 사용하여 FlowFile 에서 레코드 스키마 열을 추출하여’스키마’에 씁니다. |
|
Box AI 를 사용하여 Box 파일에서 메타데이터를 추출합니다. |
||
FlowFile 의 내용에 대해 1개 이상의 정규식을 평가합니다. |
F¶
프로세서 |
설명 |
|
---|---|---|
Azure Blob Storage에서 지정된 Blob을 검색하고 해당 내용을 FlowFile 의 내용에 씁니다. |
||
Azure Data Lake Storage에서 지정된 파일 가져오기 |
||
박스 폴더에서 파일을 가져옵니다. |
||
Box에서 파일에 대한 메타데이터를 가져와 FlowFile 의 특성에 추가합니다. |
||
템플릿 키와 범위를 사용하여 Box 파일과 연결된 특정 메타데이터 인스턴스를 검색합니다. |
||
표현 힌트를 사용하여 Box 파일 표현을 가져와 FlowFile 내용에 씁니다. |
||
각 수신 FlowFile 에 대해 FlowFile 특성에서 캐시 키를 계산하고 각 키와 연결된 분산 맵 캐시에서 값을 가져옵니다. |
||
Dropbox에서 파일을 가져옵니다. |
||
디스크에서 파일의 내용을 읽고 수신 FlowFile 의 내용으로 스트림합니다. |
||
원격 FTP 서버에서 파일 내용을 가져와서 수신 FlowFile 의 내용을 원격 파일의 내용으로 덮어씁니다. |
||
Google Cloud Bucket에서 파일을 가져옵니다. |
||
Google Drive Folder에서 파일을 가져옵니다. |
||
Snowflake |
Google Drive 파일에 대한 설명과 해당 댓글을 가져옵니다. |
|
Snowflake |
Google Drive 파일 메타데이터를 가져옵니다. |
|
GridFS 버킷에서 파일 이름 또는 사용자 정의 쿼리로 1개 이상의 파일을 검색합니다. |
||
Snowflake |
구성 가능한 검색 옵션이 있는 REST API v3을 사용하여 Jira Cloud에서 문제를 가져옵니다. |
|
Snowflake |
Microsoft Dataverse 테이블에서 레코드 가져오기 |
|
S3 오브젝트의 내용을 가져와 FlowFile 의 내용으로 기록합니다. |
||
원격 SFTP 서버에서 파일 내용을 가져와서 수신 FlowFile 의 내용을 원격 파일의 내용으로 덮어씁니다. |
||
Snowflake |
Sharepoint Drive에서 파일의 내용을 가져오고, 해당되는 경우 PDF 또는 HTML 버전의 파일을 선택적으로 다운로드합니다. |
|
Snowflake |
각 드라이브 항목에 대해 해당 메타데이터와 권한을 검색하여 FlowFile 특성으로 기록합니다. |
|
Snowflake |
Slack 대화 정보 및 멤버 이메일 가져오기 |
|
Snowflake |
Slack에서 공유된 파일을 다운로드합니다. |
|
Snowflake |
단일 Slack 메시지에 대한 데이터 가져오기 |
|
SMB 공유에서 파일을 가져옵니다. |
||
Snowflake |
테이블에서 속성을 읽고 이를 플로우 파일 특성으로 저장합니다. |
|
Snowflake |
테이블 스키마를 가져옵니다(즉, |
|
Snowflake |
데이터베이스에서 테이블의 스냅샷을 가져옵니다. |
|
지정된 특성은 유지하고 나머지는 제거하거나 지정된 특성은 제거하고 나머지는 유지하는 방식으로 FlowFile 의 특성을 필터링합니다. |
||
Snowflake |
드라이브 ID 및 항목 경로로 SharePoint 드라이브 항목을 찾습니다. |
|
사용자에게 중첩된 JSON 문서를 간단한 키-값 페어 문서로 데이터 스큐를 수행할 수 있는 기능을 제공합니다. |
||
JoinEnrichment 프로세서와 함께 사용되는 이 프로세서는 JoinEnrichment 프로세서가 함수를 수행하는 데 필요한 특성을 추가하는 역할을 합니다. |
||
이 프로세서를 통해 사용자는 1개의 레코드를 여러 개의 레코드로 포크할 수 있습니다. |
G¶
프로세서 |
설명 |
|
---|---|---|
Snowflake |
대규모 언어 모델(LLM)을 사용하여 수신 레코드에 있는 각 질문에 대한 합성 답변을 생성합니다. |
|
Snowflake |
LLM 을 사용하여 수신 레코드의 각 질문에 대한 합성 답변을 생성합니다. |
|
이 프로세서는 임의의 데이터 또는 사용자 정의 내용으로 FlowFiles 을 생성합니다. |
||
Snowflake |
구성 가능한 JSON 스키마를 기반으로 임의의 필드 값을 가진 JSON 오브젝트 배치를 생성합니다. |
|
이 프로세서는 지정된 필드에 대해 임의의 값을 갖는 레코드로 FlowFiles 을 생성합니다. |
||
테이블에서 행의 ‘페이지’를 가져오는 SQL select 쿼리를 생성합니다. |
||
IP 주소의 지리적 위치 정보를 조회하고 FlowFile 특성에 지리적 정보를 추가합니다. |
||
IP 주소의 지리적 위치 정보를 조회하고 FlowFile 특성에 지리적 정보를 추가합니다. |
||
Snowflake |
준비되면 프로세서가 Amazon Ads에서 보고서를 다운로드합니다. |
|
AWS Polly 작업의 현재 상태를 검색합니다. |
||
AWS Textract 작업의 현재 상태를 검색합니다. |
||
AWS Transcribe 작업의 현재 상태를 검색합니다. |
||
AWS Translate 작업의 현재 상태를 검색합니다. |
||
안정적인 체크포인트 추적 없이 Microsoft Azure Event Hubs에서 메시지를 수신합니다. |
||
Azure Queue Storage에서 메시지를 검색합니다. |
||
Box 파일에 있는 모든 공동 작업자를 검색하고 FlowFile 의 특성에 공동 작업 정보를 추가합니다. |
||
Box 그룹의 멤버을 검색하고 FlowFile 특성에 세부 정보를 기록합니다. |
||
Snowflake |
Salesforce 데이터 클라우드에서 지정된 데이터 공유 메타데이터를 설명합니다. |
|
Snowflake |
Salesforce 데이터 클라우드에서 지정된 데이터 공유 메타데이터를 설명합니다. |
|
Snowflake |
DBFS 파일을 읽습니다. |
|
해시 및 범위 키를 기준으로 DynamoDB 에서 문서를 검색합니다. |
||
공식 Elastic REST 클라이언트 라이브러리를 사용하여 _id로 Elasticsearch에서 단일 문서를 가져오는 Elasticsearch get 프로세서입니다. |
||
디렉터리에 있는 파일에서 FlowFiles 을 생성합니다. |
||
이 프로세서는 구성된 파일 리소스의 내용으로 FlowFiles 을 생성합니다. |
||
FTP 서버에서 파일을 가져와 FlowFiles 을 생성합니다 |
||
Google Vision 작업의 현재 상태를 검색합니다. |
||
Google Vision 작업의 현재 상태를 검색합니다. |
||
Snowflake |
Google Ads Reporting API 와 상호 작용할 수 있는 프로세서입니다. |
|
Snowflake |
FlowFile 특성으로 지정된 그룹 IDs 를 쉼표로 구분한 목록으로 지정된 1개 이상 Google 그룹의 멤버를 검색합니다. |
|
Snowflake |
Google Sheets에서 데이터를 가져오는 작업을 담당하는 프로세서입니다. |
|
비공개 HubSpot 애플리케이션에서 JSON 데이터를 검색합니다. |
||
Snowflake |
HubSpot 오브젝트와 그 연관성을 ID 또는 고유 값으로 가져옵니다. |
|
Snowflake |
LinkedIn Reporting APIs 에서 메트릭을 다운로드하는 프로세서. |
|
Snowflake |
Microsoft365 그룹 멤버를 검색하고 변경이 발생할 때마다 FlowFile 을 전송합니다. |
|
사용자 지정 쿼리로 로딩된 MongoDB 의 문서에서 FlowFiles 을 생성합니다. |
||
Record Writer를 사용하여 MongoDB 결과 세트를 작성하는 GetMongo 의 레코드 기반 버전입니다. |
||
Snowflake |
Bulk API 2를 사용하여 Salesforce에서 쿼리 작업의 결과를 가져옵니다. |
|
Snowflake |
Bulk API 2를 사용하여 Salesforce에서 쿼리 작업의 상태를 가져옵니다. |
|
S3에서 오브젝트의 존재를 확인하고 다운로드를 시도하지 않고 메타데이터를 가져옵니다. |
||
S3에서 오브젝트의 존재를 확인하고 다운로드하지 않고 해당 태그를 가져옵니다. |
||
SFTP 서버에서 파일을 가져와 FlowFiles 을 생성합니다 |
||
Snowflake |
SharePoint 사이트 그룹의 모든 멤버를 검색합니다. |
|
사용자 지정 Shopify 스토어에서 오브젝트를 검색합니다. |
||
samba 네트워크 위치에서 FlowFiles 로 파일을 읽습니다. |
||
Splunk Enterprise에서 데이터를 검색합니다. |
||
Amazon Simple Queuing Service 큐에서 메시지를 가져옵니다 |
||
Snowflake |
최대 5 GiB 까지 Unity Catalog 파일을 읽습니다. |
|
Snowflake |
Unity Catalog 파일 메타데이터를 확인합니다. |
|
구성 가능한 Workday 보고서와 상호 작용할 수 있는 프로세서입니다. |
||
Zendesk API 에서 데이터를 점진적으로 가져옵니다. |
H¶
프로세서 |
설명 |
|
---|---|---|
HTTP 서버를 시작하고 HTTP 요청을 수신 대기합니다. |
||
FlowFile 을 생성한 요청자에게 HTTP 응답을 보냅니다. |
I¶
프로세서 |
설명 |
|
---|---|---|
FlowFile 에 사용되는 MIME 유형을 식별하려고 시도합니다. |
||
구성 가능한 HTTP 엔드포인트와 상호 작용할 수 있는 HTTP 클라이언트 프로세서입니다. |
||
실험적 - 지정된 스크립트에 정의된 프로세서에 대한 스크립트 엔진을 호출합니다. |
||
IP 주소에 대한 ISP 정보를 조회하고 FlowFile 특성에 정보를 추가합니다. |
J¶
프로세서 |
설명 |
|
---|---|---|
서로 다른 2개의 FlowFiles 에서 레코드를 결합하는 것으로, 1개의 FlowFile 인 ‘원본’에는 임의의 레코드가 포함되어 있고 두 번째 FlowFile 인 ‘보강’에는 첫 번째를 보강하는 데 사용해야 하는 추가 데이터가 포함되어 있습니다. |
||
FlowFile JSON 내용 또는 지정된 FlowFile JSON 특성에 Jolt 사양 목록을 적용합니다. |
||
FlowFile 페이로드의 각 레코드에 JOLT 사양을 적용합니다. |
||
FlowFile JSON 페이로드에 JSLT 변환을 적용합니다. |
||
사용자가 Elasticsearch JSON DSL 로 작성된 쿼리(집계 포함)를 실행할 수 있는 프로세서입니다. |
L¶
프로세서 |
설명 |
|
---|---|---|
Snowflake |
선택한 오브젝트 타입에 대해 HubSpot 에서 아카이브된 데이터를 목록에 나열하고 해당 메타데이터를 FlowFile 특성으로 하여 나열된 오브젝트당 1개씩 FlowFile 을 생성합니다. |
|
Azure Blob Storage 컨테이너에 있는 Blob을 목록으로 표시합니다. |
||
Azure Data Lake Storage Gen 2 파일 시스템의 디렉터리 목록 표시 |
||
Box 폴더에 있는 파일을 목록으로 표시합니다. |
||
Box 폴더의 각 파일에 대한 파일 메타데이터를 가져옵니다. |
||
Box 파일과 연결된 모든 메타데이터 인스턴스를 검색합니다. |
||
Box 파일과 연결된 모든 메타데이터 템플릿을 검색합니다. |
||
데이터베이스 연결에서 테이블에 대한 메타데이터에 해당하는 특성을 각각 포함하는 플로우 파일 세트를 생성합니다. |
||
Snowflake |
DBFS 디렉터리에 파일 이름을 나열하고 파일 이름으로 FlowFile 을 새로 출력합니다. |
|
Dropbox에서 파일 목록을 검색합니다(바로 가기는 무시됨). |
||
지정된 포트에서 수신 대기하는 FTP 서버를 시작하고 수신 파일을 FlowFiles 로 변환합니다. |
||
HTTP 서버를 시작하고 지정된 기본 경로에서 수신 요청을 FlowFiles 로 변환하기 위해 수신 대기합니다. |
||
HTTP 또는 gRPC 를 통해 OpenTelemetry 메시지를 수집합니다. |
||
1개 이상의 Slack 대화에서 실시간 메시지 또는 Slack 명령을 검색합니다. |
||
TCP 또는 UDP 를 통해 지정된 포트로 전송되는 Syslog 메시지를 수신 대기합니다. |
||
수신 TCP 연결을 수신 대기하고 줄 바꿈 구분자를 메시지 구분 기호로 사용하여 각 연결에서 데이터를 읽습니다. |
||
지정된 포트에서 데이터그램 패킷을 수신 대기합니다. |
||
지정된 포트에서 데이터그램 패킷을 수신 대기하고 구성된 Record Reader를 사용하여 각 데이터그램의 내용을 읽습니다. |
||
클라이언트 연결을 수락하는 WebSocket 서버 엔드포인트 역할을 합니다. |
||
입력 디렉터리에서 파일 목록을 검색합니다. |
||
FTP 서버에 있는 파일 목록을 수행합니다. |
||
GCS 버킷에서 오브젝트 목록을 검색합니다. |
||
Google Drive 폴더에 있는 구체적인 파일 목록(바로 가기는 무시됨)을 수행합니다. |
||
Snowflake |
지정된 Google Drive에 있는 모든 파일과 폴더를 목록으로 표시합니다. |
|
Snowflake |
Google Workspace에서 지정된 도메인에 대한 모든 그룹을 목록으로 표시합니다. |
|
Snowflake |
지정된 오브젝트 타입에 대해 HubSpot 에서 데이터를 가져오고, 나열된 오브젝트당 1개씩 FlowFile 을 생성하며, 해당 메타데이터를 FlowFile 특성으로 추가합니다. |
|
Snowflake |
Microsoft Dataverse 환경에서 테이블 목록 생성하기 |
|
S3 버킷에서 오브젝트 목록을 검색합니다. |
||
Snowflake |
식별된 사용자가 사용할 수 있는 조직에서 사용 가능한 데이터 공유를 나열합니다. |
|
Snowflake |
식별된 사용자가 사용할 수 있는 조직 내 사용 가능한 오브젝트를 나열합니다. |
|
SFTP 서버에 있는 파일 목록을 수행합니다. |
||
Snowflake |
지정된 SharePoint 사이트에 있는 각 드라이브에 대해 FlowFile 을 전송합니다. |
|
Snowflake |
지정된 SharePoint 사이트에서 사용 가능한 모든 SharePoint 사이트 그룹을 목록으로 표시합니다. |
|
SMB 프로토콜을 통해 공유된 구체적인 파일을 목록으로 표시합니다. |
||
Snowflake |
모든 소스 테이블 이름을 가져와서 가능한 구성 중 하나인 - regexp expression e와 일치시킵니다. |
|
Snowflake |
Unity Catalog 디렉터리에서 파일 이름을 나열하고 파일 이름으로FlowFile을 새로 출력합니다. |
|
지정된 로그 수준에서 FlowFile 의 특성을 방출합니다 |
||
지정된 로그 수준에서 로그 메시지를 내보냅니다 |
||
조회 서비스에서 특성 조회하기 |
||
레코드에서 1개 이상의 필드를 추출하고 LookupService 에서 해당 필드에 대한 값을 조회합니다. |
M¶
프로세서 |
설명 |
|
---|---|---|
사용자 정의 전략에 따라 FlowFiles 그룹을 병합하여 단일 FlowFile 로 패키지화합니다. |
||
이 프로세서는 여러 개의 레코드 지향 FlowFiles 을 입력된 FlowFiles 의 모든 레코드를 포함하는 단일 FlowFile 로 병합합니다. |
||
Snowflake |
저널 테이블에서 대상 테이블로의 변경 사항에 대해 Snowflake에서 병합 작업을 트리거합니다. |
|
이진 파일의 시작과 끝 또는 모든 내용의 바이트 범위를 삭제합니다. |
||
사용자가 지정한 압축 알고리즘을 사용하여 FlowFiles 의 내용을 압축 해제하고 지정된 압축 형식 속성을 사용하여 내용을 다시 압축하여 FlowFile 의 내용을 압축하는 데 사용되는 압축 알고리즘을 변경합니다. |
||
플로우의 활동을 모니터링하고 플로우에 지정된 시간 동안 데이터가 없는 경우 표시기를 보내고 플로우의 활동이 복원되면 다시 표시기를 보냅니다 |
||
Azure Data Lake Storage Gen 2 내에서 내용을 이동합니다. |
N¶
프로세서 |
설명 |
|
---|---|---|
선택적으로 FlowFile 의 특성과 함께 릴리스 신호 식별자를 분산 캐시에 캐시합니다. |
O¶
프로세서 |
설명 |
|
---|---|---|
Snowflake |
오디오를 영어 텍스트로 변환합니다. |
P¶
프로세서 |
설명 |
|
---|---|---|
이 프로세서는 FlowFile 특성과 내용을 NiFi 에서 내보내고 NiFi 로 다시 가져올 수 있는 출력 FlowFile 로 패키지화하여 원래 특성과 내용을 보존합니다. |
||
사용자가 Elasticsearch JSON DSL 로 작성된 페이지 매김 쿼리(집계 포함)를 실행할 수 있는 프로세서입니다. |
||
Windows Event Log 파일(evtx)의 내용을 구문 분석하고 그 결과 XML 을 FlowFile 에 씁니다. |
||
Snowflake |
Excel 셀 참조 수식 구문 분석을 담당하는 프로세서입니다. |
|
RFC5424 및 RFC3164 형식에 따라 Syslog 메시지의 내용을 구문 분석하고 Syslog 메시지의 각 부분에 대해 FlowFile 에 특성을 추가하려고 시도합니다. |
||
잘 구성된 Syslog 메시지의 내용을 RFC5424 형식에 따라 구문 분석을 시도하고 정형 데이터를 포함한 Syslog 메시지의 각 부분에 대해 FlowFile 에 특성을 추가합니다. |
||
데이터에 구성된 필드를 기반으로 레코드 중심의 데이터를 분할 또는 파티션합니다. |
||
Snowflake |
Snowflake Cortex ML 함수를 사용하여 PDF 문서에서 광학 문자 인식(OCR)을 수행합니다. |
|
Snowflake |
정규화된 테이블 이름 목록을 받아 테이블이 - 신규(복제되지 않았지만 소스에 추가됨) - 기존(복제되었고 소스에 존재함) - 부실(복제되었지만 소스에 더 이상 존재하지 않음)인지를 결정합니다. 구성은 FlowFile 특성으로 전달됩니다. |
|
Snowflake |
응답을 FlowFile 특성으로 작성하거나 수신 FlowFile 의 내용으로 작성하여 Anthropic에 프롬프트를 보냅니다. |
|
Snowflake |
응답을 FlowFile 특성 또는 수신 FlowFile 의 내용으로 작성하여 Azure의 OpenAI 서비스로 프롬프트를 보냅니다. |
|
Snowflake |
이 프로세서는 사용자 정의 프롬프트를 대규모 언어 모델(LLM)로 전송하여 응답합니다. |
|
Snowflake |
FlowFile 특성 또는 수신 FlowFile 의 내용으로 응답을 작성하여 OpenAI 로 프롬프트를 보냅니다. |
|
Snowflake |
응답을 FlowFile 특성 또는 수신 FlowFile 의 내용으로 작성하여 Snowflake Cortex에 프롬프트를 보냅니다. |
|
Snowflake |
FlowFile 특성 또는 수신 FlowFile 의 내용으로 응답을 작성하여 VertexAI 로 프롬프트를 보냅니다. |
|
FlowFile 의 내용으로 AMQP 메시지를 생성하고 AMQP Exchange로 메시지를 보냅니다. |
||
수신 flowfile의 내용을 구성된 Google Cloud PubSub 토픽에 게시합니다. |
||
FlowFile 의 내용으로 JMS 메시지를 생성하고 JMS BytesMessage 또는 TextMessage 로 JMS 대상(큐 또는 항목)으로 보냅니다. |
||
FlowFile 의 내용을 메시지 또는 개별 레코드로서 Kafka Producer API 를 사용하여 Apache Kafka로 전송합니다. |
||
Snowflake |
FlowFile 의 내용을 메시지 또는 개별 레코드로서 Kafka Producer API 를 사용하여 Apache Kafka로 전송합니다. |
|
MQTT 항목에 메시지를 게시합니다 |
||
지정된 Slack 채널에 메시지를 게시합니다. |
||
내용을 Azure Blob Storage의 Blob에 넣습니다. |
||
이 프로세서는 Core SQL API 를 사용하여 Cosmos DB 에 데이터를 삽입하기 위한 레코드 인식 프로세서입니다. |
||
제공된 엔드포인트로 FlowFiles 을 전송하는 Azure 데이터 탐색기 싱크 역할을 합니다. |
||
FlowFile 의 내용을 Azure Data Lake Storage Gen 2에 파일로 씁니다 |
||
FlowFile 내용을 Azure Event Hubs로 보내기 |
||
수신 FlowFiles 의 내용을 구성된 Azure Queue Storage에 씁니다. |
||
FlowFile 의 내용을 Google BigQuery 테이블에 씁니다. |
||
Box 폴더에 내용을 넣습니다. |
||
Amazon CloudWatch 에 메트릭을 게시합니다. |
||
PutDatabaseRecord 프로세서는 지정된 RecordReader 를 사용하여 수신 플로우 파일에서 (여러 개일 수 있는) 레코드를 입력합니다. |
||
Snowflake |
Databricks REST API 를 사용하여 SQL 실행을 제출한 다음 JSON 응답을 FlowFile 내용에 작성합니다. |
|
Snowflake |
FlowFile 내용을 DBFS 로 작성합니다. |
|
FlowFile 특성에서 계산된 캐시 키를 사용하여 FlowFile 의 내용을 가져와 분산 맵 캐시에 저장합니다. |
||
Dropbox 폴더에 내용을 넣습니다. |
||
해시 및 범위 키에 따라 DynamoDB 의 문서를 넣습니다. |
||
레코드 지향 데이터를 기반으로 DynamoDB 에 항목을 삽입합니다. |
||
공식 Elastic REST 클라이언트 라이브러리를 사용하는 Elasticsearch 풋 프로세서입니다. |
||
공식 Elastic REST 클라이언트 라이브러리를 사용하는 레코드 인식 Elasticsearch put 프로세서입니다. |
||
각 수신 FlowFile 에 대해 구성된 수신자에게 이메일을 보냅니다 |
||
FlowFile 의 내용을 로컬 파일 시스템에 씁니다 |
||
FlowFiles 을 FTP 서버로 전송합니다 |
||
FlowFile 의 내용을 Google Cloud Storage에 오브젝트로 씁니다. |
||
FlowFile 의 내용을 Google Drive에 파일로 씁니다. |
||
GridFS 버킷에 파일을 씁니다. |
||
Snowflake |
HubSpot 오브젝트를 업서트합니다. |
|
Snowflake |
네임스페이스와 테이블을 관리하기 위해 구성 가능한 카탈로그를 사용하여 Iceberg에 레코드를 저장합니다. |
|
지정된 Amazon Kinesis Firehose로 내용을 전송합니다. |
||
지정된 Amazon Kinesis로 내용을 전송합니다. |
||
내용을 지정된 Amazon Lambda 함수로 보냅니다. |
||
FlowFile의 내용을 MongoDB 로 씁니다 |
||
FlowFile 의 내용을 MongoDB 에 일괄 업데이트로 씁니다 |
||
이 프로세서는 MongoDB 에 데이터를 삽입/업서트하기 위한 레코드 인식 프로세서입니다. |
||
PutRecord 프로세서는 지정된 RecordReader 를 사용하여 수신 플로우 파일에서 (여러 개일 수 있는) 레코드를 입력한 후 레코드 대상 서비스에서 지정한 대상으로 전송합니다. |
||
해시 값이 포함된 각 레코드의 필드에 RecordPath 에 의해 결정되는 지정된 해시 값을 사용하여 레코드 필드 데이터를 Redis에 넣습니다. |
||
FlowFile 의 내용을 Amazon S3 버킷에 S3 오브젝트로 씁니다. |
||
지정된 Salesforce sObject에 대한 새 레코드를 생성합니다. |
||
FlowFiles 을 SFTP 서버로 전송합니다 |
||
FlowFile 의 내용을 samba 네트워크 위치에 씁니다. |
||
Snowflake |
파일을 Snowflake 내부 스테이지에 넣습니다. |
|
Snowflake |
레코드를 Snowflake 테이블로 스트림합니다. |
|
FlowFile 의 내용을 Amazon 간편 알림 서비스에 알림으로 보냅니다 |
||
TCP, TCP + TLS/SSL 또는 UDP 를 통해 로그를 Splunk Enterprise로 전송합니다. |
||
HTTP 또는 HTTPS 를 통해 지정된 Splunk 서버로 플로우 파일 내용을 전송합니다. |
||
SQL UPDATE 또는 INSERT 명령을 실행합니다. |
||
Amazon Simple Queuing Service 큐에 메시지를 게시합니다 |
||
TCP 또는 UDP 를 통해 지정된 호스트와 포트로 Syslog 메시지를 전송합니다. |
||
직렬화된 FlowFiles 또는 레코드를 TCP 를 통해 구성 가능한 대상으로 전송하며, TLS 를 옵션으로 지원합니다. |
||
PutUDP 프로세서는 FlowFile 을 수신하고 FlowFile 내용을 단일 UDP 데이터그램 패킷으로 패키징한 다음 구성된 UDP 서버로 전송합니다. |
||
Snowflake |
Unity Catalog에 최대 5 GiB 크기의 FlowFile 내용을 작성합니다. |
|
Snowflake |
JSON 문서를 생성하여 Vectara의 업로드 엔드포인트에 업로드합니다. |
|
Snowflake |
FlowFile 내용을 Vectara의 인덱스 엔드포인트에 업로드합니다. |
|
ListenWebSocket 또는 ConnectWebSocket 에서 설정한 WebSocket 세션을 사용하여 WebSocket 원격 엔드포인트로 메시지를 보냅니다. |
||
Zendesk API 를 사용하여 Zendesk 티켓을 생성합니다. |
Q¶
프로세서 |
설명 |
|
---|---|---|
Azure 데이터 탐색기를 쿼리하고 JSON 결과를 출력 FlowFiles 로 스트리밍합니다. |
||
SQL select 쿼리를 생성하거나 제공된 문을 사용하여 실행하여 지정된 최대값 열의 값이 이전에 표시된 최대값보다 큰 모든 행을 가져옵니다. |
||
SQL select 쿼리를 생성하거나 제공된 문을 사용하여 실행하여 지정된 최대값 열의 값이 이전에 표시된 최대값보다 큰 모든 행을 가져옵니다. |
||
Snowflake |
벡터를 사용하여 Milvus 데이터베이스에서 지정된 컬렉션을 쿼리합니다. |
|
Snowflake |
입력 벡터와 유사한 벡터를 Pinecone에 쿼리하거나 ID 로 벡터를 검색합니다. |
|
FlowFile 의 내용에 대해 1개 이상의 SQL 쿼리를 평가합니다. |
||
Salesforce sObject에서 레코드를 검색합니다. |
||
인덱스 승인 상태를 얻기 위해 Splunk 서버에 쿼리합니다. |
R¶
프로세서 |
설명 |
|
---|---|---|
레코드 지향 데이터를 포함하는 FlowFile 의 내용을 수정했습니다. |
||
FlowFile 의 각 레코드에서 1개 이상의 필드 이름을 바꿉니다. |
||
FlowFile 내용에서 일부 텍스트 값(정규식/regex 또는 리터럴 값)을 검색하고 일치하는 내용 섹션을 일부 대체 값으로 대체하여 FlowFile 의 내용을 업데이트합니다. |
||
정규식을 기준으로 평가하고 정규식과 일치하는 내용 섹션을 매핑 파일에 제공된 대체 값으로 대체하여 FlowFile 의 내용을 업데이트합니다. |
||
이 프로세서로 전달된 FlowFiles 에는 구성된 ‘최대 재시도 횟수’ 값에 대해 ‘재시도 특성’ 값이 선택되어 있습니다. |
||
특성 표현식 언어를 사용하여 특성에 따라 FlowFiles 을 라우팅합니다. |
||
FlowFile 의 내용에 정규식을 적용하고 정규식이 일치하는 각 대상에 FlowFile 의 복사본을 라우팅합니다. |
||
사용자가 정의한 규칙 세트를 기반으로 텍스트 데이터를 라우팅합니다. |
||
Snowflake |
사용자 정의 매개 변수를 사용하여 미리 정의된 Databricks 작업이 실행되도록 트리거합니다. |
|
flowfile이 수신될 때마다 집계 쿼리를 실행하는 프로세서입니다. |
S¶
프로세서 |
설명 |
|
---|---|---|
지정된 Sampling Strategy(예: 저장소 샘플링)에 따라 FlowFile 의 레코드를 샘플링합니다. |
||
FlowFiles 의 지정된 특성을 스캔하여 지정된 용어 사전 내에 해당 값이 있는지 확인합니다 |
||
FlowFiles 의 내용을 스캔하여 사용자가 제공한 사전에서 찾은 용어를 검색합니다. |
||
이 프로세서는 사용자가 제공한 스크립트를 사용하여 FlowFiles 에서 레코드를 필터링하는 기능을 제공합니다. |
||
레코드 지향 데이터를 수신합니다(즉, |
||
수신 FlowFile 의 각 레코드에 대해 간단한 스크립트를 평가하는 기능을 제공합니다. |
||
이 프로세서는 사용자가 제공한 스크립트를 사용하여 FlowFiles 에서 레코드의 유효성을 검사하는 기능을 제공합니다. |
||
사용자가 Elasticsearch JSON DSL 로 작성된 페이지 매김 쿼리(집계 포함)를 반복적으로 실행할 수 있는 프로세서입니다. |
||
FlowFile 을 바이트 경계에서 여러 개의 작은 세그먼트로 분할합니다. |
||
OpenPGP 개인 키를 사용하여 내용에 서명합니다. |
||
Snowflake |
FlowFile 의 해시(FlowFile특성으로 제공됨)가 이미 Snowflake 테이블에 있는지 확인하고, 발견되면 FlowFile 을 ‘중복’, 발견되지 않으면 ‘고유’, 오류 시 ‘실패’로 라우팅합니다. |
|
이진 인코딩된 Avro 데이터 파일을 구성된 출력 크기에 따라 더 작은 파일로 분할합니다. |
||
수신 FlowFiles 을 지정된 바이트 시퀀스로 분할합니다 |
||
이 프로세서는 여러 장의 Microsoft Excel 스프레드시트를 여러 개의 Microsoft Excel 스프레드시트로 분할하여 원본 파일의 각 시트를 자체 플로우 파일에 있는 개별 스프레드시트로 변환합니다. |
||
JSON 파일을 JsonPath 식에 지정된 배열 요소에 대해 별도의 FlowFiles 파일 여러 개로 분할합니다. |
||
레코드 지향 데이터 형식의 입력 FlowFile 을 여러 개의 작은 FlowFiles 로 분할합니다. |
||
최대 줄 수 또는 조각의 총 크기로 제한되는 줄 경계에서 텍스트 파일을 여러 개의 작은 텍스트 파일로 분할합니다. |
||
XML 파일을 각각 원래 루트 요소의 하위 또는 하위 요소로 구성된 여러 개의 개별 FlowFiles 로 분할합니다 |
||
AWS Polly 작업을 트리거합니다. |
||
AWS Textract 작업을 트리거합니다. |
||
AWS Transcribe 작업을 트리거합니다. |
||
AWS Translate 작업을 트리거합니다. |
||
파일 입력 시 비전 작업을 트리거합니다. |
||
이미지 입력 시 비전 작업을 트리거합니다. |
||
Snowflake |
Bulk API 2를 사용하여 Salesforce로 쿼리 작업을 제출합니다. |
|
Snowflake |
이 프로세서는 대규모 언어 모델(LLM)을 사용하여 FlowFile 의 내용을 요약합니다. |
T¶
프로세서 |
설명 |
|
---|---|---|
Amazon S3 오브젝트에 태그를 추가하거나 업데이트합니다. |
||
파일 또는 파일 목록을 ‘테일링’하여 파일에 기록될 때 파일에서 데이터를 수집합니다. |
||
제공된 XSLT 파일을 FlowFile XML 페이로드에 적용합니다. |
U¶
프로세서 |
설명 |
|
---|---|---|
여러 가지 패키지 형식 중 하나로 패키징된 FlowFiles 의 내용을 언패킹하여 각 입력 FlowFile 에 대해 하나에서 여러 개의 FlowFiles 을 전송합니다. |
||
특성 표현식 언어를 사용하여 FlowFile 의 특성을 업데이트하거나 정규식을 기반으로 특성을 삭제합니다 |
||
지정된 flowfile의 레코드를 사용하여 Box 파일의 메타데이터 템플릿 값을 업데이트합니다. |
||
쿼리를 사용해 Elasticsearch 인덱스에서 문서를 업데이트합니다. |
||
이 프로세서를 통해 사용자는 플로우에서 특정 카운터와 키 포인트를 설정할 수 있습니다. |
||
이 프로세서는 JDBC 연결과 수신 레코드를 사용하여 수신 레코드를 지원하는 데 필요한 데이터베이스 테이블 변경 사항을 생성합니다. |
||
레코드 지향 데이터를 포함하는 FlowFile 의 내용을 업데이트합니다. |
||
Snowflake |
수신 FlowFile 에 제공된 스키마를 기반으로 Snowflake 테이블의 정의를 업데이트합니다. |
|
Snowflake |
Snowflake Iceberg 테이블의 정의를 업데이트합니다. |
|
Snowflake |
테이블 상태 서비스에서 테이블의 상태를 업데이트합니다 |
|
Snowflake |
주어진 컬렉션에 대해 Milvus 데이터베이스에 벡터를 업서트합니다 |
|
Snowflake |
메타데이터를 포함한 벡터와 선택적으로 텍스트를 Pinecone 인덱스에 게시합니다. |
|
Snowflake |
수신 FlowFile 의 레코드를 Salesforce에 업서트합니다 |
V¶
프로세서 |
설명 |
|
---|---|---|
FlowFiles 또는 FlowFile 특성 값의 내용을 사용자가 지정한CSV스키마와 비교하여 유효성을 검사합니다. |
||
구성 가능한 JSON 스키마에 대해 FlowFiles 의 내용을 검증합니다. |
||
수신되는FlowFile의 레코드를 주어진 스키마와 비교하여 유효성을 검사합니다. |
||
FlowFile 에 포함된 XML 의 유효성을 검사합니다. |
||
제공된 시크릿 키를 사용하여 메시지 인증 코드를 계산하고 제공된 MAC 속성과 비교합니다 |
||
OpenPGP 공개 키를 사용하여 서명을 확인합니다 |
W¶
프로세서 |
설명 |
|
---|---|---|
해당 Notify 프로세서에서 일치하는 릴리스 신호가 분산 캐시에 저장될 때까지 수신 FlowFiles 을 ‘대기’ 관계로 라우팅합니다. |
||
Snowflake |
해당 테이블 상태가 허용 상태와 같지 않을 때까지 수신 FlowFiles 을 차단합니다. |