全プロセッサー (アルファベット順)

このトピックでは、すべての Snowflake openflow プロセッサーのリストをアルファベット順に示します。リストには次が含まれます。

  • 各プロセッサー名

  • 各プロセッサーの概要

A

プロセッサー

説明

Snowflake

AbortQueryJob

一括 API 2 を使用してSalesforce でクエリジョブを中断

AttributesToCSV

入力 FlowFile 属性の CSV 表現を生成します。

AttributesToJSON

入力 FlowFile 属性の JSON 表現を生成します。

C

プロセッサー

説明

CalculateRecordStats

記録セット内の記録数をカウントし、オプションでカテゴリごとに要素数をカウントします(カテゴリはユーザー定義のプロパティで定義されます)。

Snowflake

CaptureChangeMySQL

MySQL データベースから CDC イベントを読み込みます。

Snowflake

CaptureChangePostgreSQL

PostgreSQL データベースから CDC イベントを読み込みます。

Snowflake

CaptureChangeSqlServer

SQL Server データベースから CDC イベントを読み込みます。

Snowflake

CaptureGoogleDriveChanges

共有Googleドライブへの変更をキャプチャし、変更が発生するたびに FlowFile を返します。

Snowflake

CaptureMicrosoft365GroupsChanges

Microsoft365 グループの変更をキャプチャし、変更が発生するたびに FlowFile を発行します。

Snowflake

CaptureSharepointChanges

Sharepoint ドキュメントライブラリから変更をキャプチャし、変更が発生するたびに FlowFile を発行します。

Snowflake

CheckMetaAdsReportReadiness

メタ広告レポートがダウンロード可能かどうかを確認するプロセッサー。

Snowflake

ChunkRecordText

区切り文字や最大文字数で再帰的に分割するオプションを使用して、テキストをチャンクします。

Snowflake

ChunkText

区切り文字や最大文字数で再帰的に分割するオプションを使用して、テキストをチャンクします。

CompressContent

ユーザー指定の圧縮アルゴリズムを使って FlowFiles のコンテンツを圧縮または伸長し、mime を更新します。

ConnectWebSocket

リモートの WebSocket サーバーと対話するための WebSocket クライアントエンドポイントとして動作します。

ConsumeAMQP

AMQP 0 を使って AMQP Broker から AMQP メッセージを消費します。

ConsumeAzureEventHub

Microsoft Azure Event Hubからのメッセージをチェックポイントで受信し、一貫したイベント処理を保証します。

ConsumeBoxEnterpriseEvents

Box admin_logs_streaming Stream Typeからエンタープライズイベントを消費します。

ConsumeBoxEvents

Boxのすべてのイベントを消費します。

ConsumeElasticsearch

Rangeクエリを使用してフィールドに対してページ分割クエリを繰り返し実行し、Elasticsearchインデックス/クエリから新しいドキュメントを消費するプロセッサーです。

ConsumeGCPubSub

構成された Google Cloud PubSub サブスクリプションからメッセージを消費します。

ConsumeIMAP

IMAP プロトコルを使用して電子メールサーバーからメッセージを消費します。

ConsumeJMS

BytesMessage, TextMessage, ObjectMessage, MapMessage または StreamMessage のタイプの JMS メッセージを消費し、その内容を FlowFile に変換し、'success' 関係に移行します。

ConsumeKafka

Apache Kafka Consumer API からメッセージを消費します。

Snowflake

ConsumeKafka

Apache Kafka Consumer API からメッセージを消費します。

ConsumeKinesisStream

指定された AWS Kinesis ストリームからデータを読み取り、処理された記録 (raw) ごとに FlowFile を出力するか、Record ReaderとRecord Writerが構成されている場合は、処理された記録のバッチに FlowFile を出力します。

ConsumeMQTT

トピックにサブスクライブし、 MQTT ブローカーからメッセージを受信します。

ConsumePOP3

POP3 プロトコルを使用して電子メールサーバーからメッセージを消費します。

ConsumeSlack

1つ以上の構成されたSlackチャンネルからメッセージを取得します。

Snowflake

ConsumeSlackConversation

本アプリで可用性のあるSlackの会話からメッセージを取得します。

Snowflake

ConsumeSlackHistory

本アプリで利用可能なすべてのSlackチャンネルから過去のメッセージを取得します。

Snowflake

ConsumeSnowflakeStream

Snowflake ストリームからデータを取得し、 FlowFile に書き込みます。

ConsumeTwitter

API v2からのツイートのストリームのTwitterのストリーミング。

ControlRate

後続プロセッサーへのデータ転送速度を制御。

ConvertCharacterSet

FlowFile の内容を、ある文字セットから別の文字セットに変換します。

ConvertRecord

構成されたRecord ReaderおよびRecord Write Controller Servicesを使用して、あるデータ形式から別のデータ形式に記録を変換します。

Snowflake

ConvertToJournalSchema

入力されたデータベーススキーマをSnowflake CDC Journalテーブルの適切なスキーマに変換します。

CopyAzureBlobStorage_v12

Azure 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

与えられたアルゴリズムを使用してフローファイルのコンテンツの暗号化ハッシュ値を計算し、出力属性に書き込みます。

D

プロセッサー

説明

DebugFlow

DebugFlow プロセッサーは、タイマーまたはcronベースのスケジュールを使用している場合、 FlowFile またはタイマーイベントの受信に応答して、 FlowFile なしでさまざまなレスポンスを明示的にトリガーできるようにすることで、 FlowFile フレームワークのテストとデバッグを支援します。

DecryptContentAge

年齢暗号化を使ってコンテンツを復号化します。

DecryptContentPGP

OpenPGP メッセージの内容を復号化します。

DeduplicateRecord

このプロセッサーは、記録セット内の個々の記録を重複除去します。

DeleteAzureBlobStorage_v12

Azure Blob Storage から指定した blob を削除します。

DeleteAzureDataLakeStorage

Azure Data Lake Storageからプロバイダーファイルを削除します。

DeleteBoxFileMetadataInstance

指定したテンプレートキーを使用して、Box ファイルからメタデータインスタンスを削除します。

DeleteByQueryElasticsearch

クエリを使用して Elasticsearch インデックスから削除します。

Snowflake

DeleteDBFSResource

DBFS ファイルとディレクトリを削除します。

DeleteDynamoDB

ハッシュと範囲キーに基づいて DynamoDB からドキュメントを削除します。

DeleteFile

ファイルシステムからファイルを削除します。

DeleteGCSObject

Google Cloud バケットからオブジェクトを削除します。

DeleteGridFS

ファイル名またはクエリを使用して、 GridFS からファイルを削除します。

Snowflake

DeleteMilvus

コレクションから Milvus データベースから ID によってベクターを削除します。

DeleteMongo

MongoDB コレクションに対して削除クエリを実行します。

Snowflake

DeletePinecone

Pinecone インデックスからベクトルを削除します。

Snowflake

DeleteQueryJob

Salesforce で一括 API 2 を使用してクエリジョブを削除します。

DeleteS3Object

Amazon S3バケットからファイルを削除します。

DeleteSFTP

SFTP サーバー上のファイルを削除します。

DeleteSQS

Amazon Simple Queuing Service Queueからメッセージを削除します。

Snowflake

DeleteUnityCatalogResource

Unityカタログのファイルまたはディレクトリを削除します。

Snowflake

DescribeDataShare

Salesforce Data Cloud の指定されたデータ共有メタデータを記述します。

Snowflake

DescribeSFDCObject

指定したオブジェクトのメタデータを Salesforce に記述します。

DetectDuplicate

各入力 FlowFile に対して、 FlowFile 属性から計算された値をキャッシュし、キャッシュされた値が既に参照されているかどうかを判断します。

DistributeLoad

ディストリビューション戦略に基づいて、 FlowFiles を下流のプロセッサーに分配します。

DuplicateFlowFile

ロード テスト用として、このプロセッサーは、 FlowFile の各入力に対して、構成された数のコピーを作成します。

E

プロセッサー

説明

EncodeContent

Base64、Base32、または16進エンコード方式を使用して、 FlowFile の内容をエンコードまたはデコードします。

EncryptContentAge

年齢暗号化を使ってコンテンツを暗号化します。

EncryptContentPGP

OpenPGP を使ってコンテンツを暗号化します。

EnforceOrder

1つのノード内で同じデータグループに属する FlowFiles の順序を強制します。

Snowflake

EnrichAttributes

構成された検索サービスを使用して値を検索し、その結果を 1 つ以上の属性として FlowFile に追加します。

Snowflake

EnrichCdcStream

CaptureChangePostgreSQL などから入ってくる FlowFiles を豊かにします。

EvaluateJsonPath

FlowFile の内容に対して、1 つ以上の JsonPath 式を評価します。

Snowflake

EvaluateRagAnswerCorrectness

F1スコア、コサイン類似度、解答の正しさなどのメトリクスを計算することで、Retrieval-Augmented Generation (RAG) コンテキストで生成された解答の正しさを評価します。

Snowflake

EvaluateRagFaithfulness

LLM (e.を使って回答を分析することにより、Retrieval-Augmented Generation (RAG) システムで生成された回答の忠実度を評価します。

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形式の電子メールファイルから添付ファイルを抽出し、個々のフローファイルに分割します。

ExtractEmailHeaders

フローファイルの内容をデータソースとして、 RFC 準拠の電子メールファイルからヘッダーを抽出し、関連する属性をフローファイルに追加します。

ExtractGrok

1つ以上の Grok 式を FlowFile の内容に対して評価し、結果を属性として追加するか、 FlowFile の内容を、マッチした内容の JSON 表記で置き換えます。

ExtractRecordSchema

付属のRecord Readerを使って FlowFile から記録スキーマを抽出し、 'avro に書き込みます。

Snowflake

ExtractSchemaColumns

付属の Record Reader を使用して FlowFile から記録スキーマ列を抽出し、 'schema に書き込みます。

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バケットからファイルを取得します。

FetchGoogleDrive

Googleドライブフォルダからファイルを取得します。

Snowflake

FetchGoogleDriveFileComments

Googleドライブファイルのコメントとその返信を取得します。

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ドライブからファイルのコンテンツを取得し、アプリケーションによっては、 PDF または HTML バージョンのファイルをダウンロードします。

Snowflake

FetchSharepointMetadata

各ドライブ・アイテムのメタデータとアクセス権を取得し、 FlowFile 属性として書き込みます。

Snowflake

FetchSlackConversationInfo

Slackの会話情報とメンバーの電子メールを取得

Snowflake

FetchSlackFile

Slackで共有されているファイルをダウンロードします。

Snowflake

FetchSlackMessage

単一のSlackメッセージに関するデータを取得します。

FetchSmb

SMB 共有からファイルを取得します。

Snowflake

FetchSnowflakeTableProperties

テーブルからプロパティを読み取り、フローファイルの属性として保存します。

Snowflake

FetchSourceTableSchema

テーブルスキーマを取得します。 (i.

Snowflake

FetchTableSnapshot

データベースからテーブルのスナップショットを取得します。

FilterAttribute

FlowFile の属性を、指定した属性を残して残りを削除する、または指定した属性を削除して残りを残すことによってフィルターします。

Snowflake

FindSharepointDriveItem

ドライブ ID とアイテムパスから Sharepoint ドライブアイテムを検索します。

FlattenJson

ネストされた JSON ドキュメントを、シンプルなキー/値ペアのドキュメントにフラット化する機能をユーザーに提供します。

ForkEnrichment

JoinEnrichment プロセッサーとともに使用されるこのプロセッサーは、 JoinEnrichment プロセッサーがその関数を実行するために必要な属性を追加する役割を果たします。

ForkRecord

このプロセッサーでは、ユーザーが記録を複数の記録に分割することができます。

G

プロセッサー

説明

Snowflake

GenerateAnswersFromContext

大容量言語モデル (LLM) を使用して、受信記録に存在する各質問に対する合成回答を生成します。

Snowflake

GenerateAnswersFromGroundTruth

LLM を使用して、入力された記録の各質問に対する合成回答を生成します。

GenerateFlowFile

このプロセッサーは、ランダムデータまたはカスタムコンテンツで FlowFiles を生成します。

Snowflake

GenerateJSON

構成可能な JSON スキーマに基づいて、ランダムなフィールド値を持つ JSON オブジェクトをバッチ生成します。

GenerateRecord

このプロセッサーは、指定されたフィールドにランダムな値を持つ記録で FlowFiles を作成します。

GenerateTableFetch

テーブルから行の「ページ」をフェッチする SQL セレクトクエリを生成します。

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イベントハブからのメッセージを受信します。

GetAzureQueueStorage_v12

Azure キューストレージからメッセージを取得します。

GetBoxFileCollaborators

Box ファイルのすべての共同作業者を取得し、その共同作業情報を FlowFile の属性に追加します。

GetBoxGroupMembers

ボックスグループのメンバーを取得し、その詳細を FlowFile 属性に書き込みます。

Snowflake

GetDataShareCredentials

Salesforce Data Cloud の指定されたデータ共有メタデータを記述します。

Snowflake

GetDataShareTables

Salesforce Data Cloud の指定されたデータ共有メタデータを記述します。

Snowflake

GetDBFSFile

DBFS ファイルを読み込みます。

GetDynamoDB

ハッシュと範囲キーに基づいて DynamoDB からドキュメントを取得します。

GetElasticsearch

Elasticsearch get processor は、公式の Elastic REST クライアントライブラリを使用し、Elasticsearch から _id によって単一のドキュメントを取得します。

GetFile

ディレクトリ内のファイルから FlowFiles を作成します。

GetFileResource

このプロセッサーは、構成されたファイルリソースの内容で FlowFiles を作成します。

GetFTP

FTP サーバーからファイルを取得し、そこから FlowFiles を作成します。

GetGcpVisionAnnotateFilesOperationStatus

Google Vision操作の現在のステータスを取得します。

GetGcpVisionAnnotateImagesOperationStatus

Google Vision操作の現在のステータスを取得します。

Snowflake

GetGoogleAdsReport

Google Ads Reporting API と相互作用できるプロセッサーです。

Snowflake

GetGoogleGroupMembers

ひとつあるいは複数の Google グループのメンバーを取得します。 FlowFile 属性で指定したグループ IDs のリストをカンマ区切りで返します。

Snowflake

GetGoogleSheets

Google Sheetsからデータを取得するプロセッサーです。

GetHubSpot

HubSpot プライベートアプリケーションから JSON データを取得します。

Snowflake

GetHubSpotObject

ID または一意な値によって、 HubSpot オブジェクトとその関連付けを取得します。

Snowflake

GetLinkedInAdsReport

LinkedIn Reporting APIs からメトリクスをダウンロードするプロセッサー。

Snowflake

GetMicrosoft365GroupMembers

Microsoft365 グループのメンバーを取得し、変更が発生するたびに FlowFile を発行します。

GetMongo

ユーザー指定のクエリによって読み込まれた MongoDB のドキュメントから FlowFiles を作成します。

GetMongoRecord

MongoDB 結果セットを書き込むために Record ライターを使用する 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カタログファイルを読み込みます。

Snowflake

GetUnityCatalogFileMetadata

Unityカタログファイルのメタデータをチェックします。

GetWorkdayReport

構成可能な Workday レポートと対話できるプロセッサー。

GetZendesk

Zendesk API からデータをインクリメンタルに取得します。

H

プロセッサー

説明

HandleHttpRequest

HTTP サーバーを起動し、 HTTP リクエストをリッスンします。

HandleHttpResponse

FlowFile を生成したリクエスト元に HTTP レスポンスを送信します。

I

プロセッサー

説明

IdentifyMimeType

FlowFile に使用されている MIME タイプの識別を試みます。

InvokeHTTP

構成可能な HTTP エンドポイントと対話できる HTTP クライアントプロセッサー。

InvokeScriptedProcessor

Experimental - 指定したスクリプトで定義された Processor のスクリプト・エンジンを起動します。

ISPEnrichIP

IP アドレスの ISP 情報を検索し、その情報を FlowFile 属性に追加します。

J

プロセッサー

説明

JoinEnrichment

2つの異なる FlowFiles の記録を結合します。1つ目の FlowFile 「オリジナル」には任意の記録が含まれ、2つ目の FlowFile 「エンリッチメント」には、1つ目のデータをエンリッチするために使用されるべき追加データが含まれます。

JoltTransformJSON

Jolt仕様のリストを、 FlowFile JSON コンテンツか、指定された FlowFile JSON 属性のどちらかに適用します。

JoltTransformRecord

FlowFile ペイロードの各記録に JOLT 仕様を適用します。

JSLTTransformJSON

FlowFile JSON ペイロードに JSLT 変換を適用します。

JsonQueryElasticsearch

Elasticsearch JSON DSL で記述されたクエリ(集約を含む)をユーザーに実行させるプロセッサーです。

L

プロセッサー

説明

Snowflake

ListArchivedHubSpotData

選択したオブジェクトタイプの HubSpot からアーカイブされたデータをリストし、対応するメタデータを FlowFile 属性として、リストされたオブジェクトごとに FlowFile を 1 つ生成します。

ListAzureBlobStorage_v12

Azure Blobストレージコンテナー内のブロブをリストします。

ListAzureDataLakeStorage

Azure Data Lake Storage Gen 2 ファイルシステム内のディレクトリをリストします。

ListBoxFile

Box フォルダ内のファイルをリストします。

ListBoxFileInfo

ボックスフォルダ内の各ファイルのメタデータを取得します。

ListBoxFileMetadataInstances

Box ファイルに関連付けられているすべてのメタデータ インスタンスを取得します。

ListBoxFileMetadataTemplates

Box ファイルに関連付けられたすべてのメタデータテンプレートを取得します。

ListDatabaseTables

データベース接続からテーブルに関するメタデータに対応する属性を含むフローファイルのセットを生成します。

Snowflake

ListDBFSDirectory

DBFS ディレクトリのファイル名をリストアップし、そのファイル名で新しい FlowFile を出力します。

ListDropbox

Dropboxからファイルのリストを取得します(ショートカットは無視されます)。

ListenFTP

指定したポートをリッスンし、受信ファイルを FlowFiles に変換する FTP サーバーを起動します。

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ドライブ内のすべてのファイルとフォルダをリスト表示します。

Snowflake

ListGoogleGroups

Google Workspace の指定したドメインのすべてのグループをリストします。

Snowflake

ListHubSpotObjects

HubSpot から指定されたオブジェクトタイプのデータを取得し、対応するメタデータを FlowFile 属性として、リストされたオブジェクトごとに FlowFile を 1 つ生成します。

Snowflake

ListMicrosoftDataverseTables

Microsoft Dataverse環境からのリストテーブル

ListS3

S3バケットからオブジェクトのリストを取得します。

Snowflake

ListSFDCDataShares

識別子ユーザーが利用可能な組織内の利用可能データ共有をリストします。

Snowflake

ListSFDCObjects

識別子ユーザーが利用可能な組織内の利用可能オブジェクトをリストします。

ListSFTP

SFTP サーバーに存在するファイルのリストをパフォーマンスします。

Snowflake

ListSharepointDrives

指定した Sharepoint Site 内に存在する各ドライブに対して FlowFile を発行します。

Snowflake

ListSharepointSiteGroups

指定された SharePoint サイトで利用可能なすべての SharePoint サイトグループをリストします。

ListSmb

SMB プロトコルで共有される具体的なファイルをリストします。

Snowflake

ListTableNames

すべてのソース・テーブル名を取得し、可能な構成の 1 つと一致させます。:- regexp 式 e.

Snowflake

ListUnityCatalogDirectory

Unityカタログのディレクトリにあるファイル名をリストアップし、そのファイル名の新しい 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イベント・ログ・ファイル(evtx)のコンテンツを解析し、 FlowFile に結果の XML を書き込みます。

Snowflake

ParseExcelCellReference

Excelのセルリファレンス式を解析するプロセッサー。

ParseSyslog

Syslogメッセージのコンテンツを RFC5424 と RFC3164 の形式に従って解析し、Syslogメッセージの各部分の FlowFile に属性を追加しようとします。

ParseSyslog5424

RFC5424 形式に従って、適切に形成されたSyslogメッセージのコンテンツの解析を試み、構造化データを含むSyslogメッセージの各部分の FlowFile に属性を追加しようとします。

PartitionRecord

データ内の構成フィールドに基づいて、記録指向のデータを分割します。

Snowflake

PerformSnowflakeCortexOCR

Snowflake Cortex ML 関数を使用して、 PDF ドキュメントで光学式文字認識 (OCR) を実行します。

Snowflake

PickTablesForReplication

完全修飾テーブル名のリストを受け入れ、テーブルが - 新しい (複製されていないが、ソースに追加された) - 存在する (複製されており、ソースに存在する) - 古い (複製されているが、ソースに存在しなくなった) かどうかを判断します。構成は FlowFile 属性として渡されます。

Snowflake

PromptAnthropicAI

Anthropicにプロンプトを送信し、レスポンスを FlowFile 属性として、または受信した FlowFile のコンテンツに書き込みます。

Snowflake

PromptAzureOpenAI

Azureの OpenAI サービスにプロンプトを送信し、レスポンスを FlowFile 属性として、または着信 FlowFile のコンテンツに書き込みます。

Snowflake

PromptLLM

このプロセッサは、ユーザー定義のプロンプトを大容量言語モデル (LLM) に送信して応答させます。

Snowflake

PromptOpenAI

プロンプトを OpenAI に送信し、その応答を FlowFile 属性として、または着信 FlowFile のコンテンツに書き込みます。

Snowflake

PromptSnowflakeCortex

Snowflake Cortexにプロンプトを送信し、レスポンスを FlowFile 属性として、または受信 FlowFile のコンテンツに書き込みます。

Snowflake

PromptVertexAI

プロンプトを VertexAI に送信し、その応答を FlowFile 属性として、または着信 FlowFile のコンテンツに書き込みます。

PublishAMQP

FlowFile のコンテンツから AMQP メッセージを作成し、そのメッセージを AMQP Exchange に送信します。

PublishGCPubSub

構成された Google Cloud PubSub トピックに受信フローファイルのコンテンツを公開します。

PublishJMS

FlowFile のコンテンツから JMS メッセージを作成し、 JMS 宛先 (キューまたはトピック) に JMS BytesMessage または TextMessage として送信します。

PublishKafka

Kafka Producer API を使用して、 FlowFile のコンテンツをメッセージまたは個々の記録として Apache Kafka に送信します。

Snowflake

PublishKafka

Kafka Producer API を使用して、 FlowFile のコンテンツをメッセージまたは個々の記録として Apache Kafka に送信します。

PublishMQTT

MQTT トピックにメッセージを公開します。

PublishSlack

指定したSlackチャンネルにメッセージを投稿します。

PutAzureBlobStorage_v12

Azure Blob Storage上のBlobにコンテンツを格納します。

PutAzureCosmosDBRecord

このプロセッサーは、Core SQL API でCosmos DB にデータを挿入するための記録認識プロセッサーです。

PutAzureDataExplorer

Azure Data Explorer のシンクとして動作し、提供されたエンドポイントに FlowFiles を送信します。

PutAzureDataLakeStorage

FlowFile のコンテンツを Azure Data Lake Storage Gen 2 上のファイルとして書き込みます。

PutAzureEventHub

FlowFile のコンテンツを Azure イベントハブに送信します。

PutAzureQueueStorage_v12

構成された Azure キューストレージに、受信 FlowFiles のコンテンツを書き込みます。

PutBigQuery

FlowFile のコンテンツを Google BigQuery のテーブルに書き込みます。

PutBoxFile

コンテンツを Box フォルダに配置します。

PutCloudWatchMetric

Amazon CloudWatch にメトリクスを公開します。

PutDatabaseRecord

PutDatabaseRecord プロセッサーは、指定された RecordReader を使用して、入力されるフローファイルから(場合によっては複数の)記録を入力します。

Snowflake

PutDatabricksSQL

Databricks REST API を使用して SQL を実行し、 JSON レスポンスを FlowFile Content に書き込みます。

Snowflake

PutDBFSFile

FlowFile のコンテンツを DBFS に書き込みます。

PutDistributedMapCache

FlowFile 属性から計算されたキャッシュキーを使用して、 FlowFile のコンテンツを取得し、分散マップキャッシュに置きます。

PutDropbox

コンテンツを Dropbox フォルダに保存します。

PutDynamoDB

ハッシュと範囲キーに基づいて DynamoDB からドキュメントを配置します。

PutDynamoDBRecord

記録指向のデータに基づいて、 DynamoDB に項目を挿入します。

PutElasticsearchJson

Elasticsearch put プロセッサー は、公式の Elastic REST クライアントライブラリを使用します。

PutElasticsearchRecord

公式の Elastic REST クライアントライブラリを使用する、記録を意識した Elasticsearch put プロセッサー です。

PutEmail

設定された受信者に、着信 FlowFile ごとに電子メールを送信します。

PutFile

FlowFile のコンテンツをローカルファイルシステムに書き込みます。

PutFTP

FTP サーバーに FlowFiles を送信します。

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 Functionにコンテンツを送信します。

PutMongo

FlowFile のコンテンツを MongoDB に書き込みます。

PutMongoBulkOperations

FlowFile のコンテンツを MongoDB に一括更新として書き込みます。

PutMongoRecord

このプロセッサーは、 MongoDB にデータを挿入/アップサートするための記録認識プロセッサーです。

PutRecord

PutRecord プロセッサーは、指定された RecordReader を使用して、受信フローファイルから(おそらく複数の)記録を入力し、Record Destination Service(すなわち、レコード宛先サービス)によって指定された宛先に送信します。

PutRedisHashRecord

指定されたハッシュ値を使用してレコードフィールドデータをRedisに格納します。このハッシュ値は、ハッシュ値を含む各レコードのフィールドへの RecordPath によって決められます。

PutS3Object

FlowFile のコンテンツを S3 オブジェクトとして Amazon S3 バケットに書き込みます。

PutSalesforceObject

指定した Salesforce sObject の新しい記録を作成します。

PutSFTP

SFTP サーバーに FlowFiles を送信します。

PutSmbFile

FlowFile のコンテンツをsambaネットワークの場所に書き込みます。

Snowflake

PutSnowflakeInternalStageFile

Snowflake内部ステージにファイルを配置します。

Snowflake

PutSnowpipeStreaming

記録をSnowflakeテーブルにストリームします。

PutSNS

FlowFile のコンテンツを Amazon Simple Notification Service に通知として送信します。

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

最大5 GiB の FlowFile コンテンツをUnityカタログに書き込みます。

Snowflake

PutVectaraDocument

JSON ドキュメントを作成し、Vectara のアップロードエンドポイントにアップロードします。

Snowflake

PutVectaraFile

Vectaraのインデックスエンドポイントに FlowFile コンテンツをアップロードします。

PutWebSocket

ListenWebSocket または ConnectWebSocket によって確立された WebSocket セッションを使用して、 WebSocket リモートエンドポイントにメッセージを送信します。

PutZendeskTicket

Zendesk API を使用して Zendesk チケットを作成します。

Q

プロセッサー

説明

QueryAzureDataExplorer

Azure Data Explorerにクエリを実行し、 JSON の結果を FlowFiles 出力にストリームします。

QueryDatabaseTable

SQL select クエリを生成するか、提供されたステートメントを使用し、それを実行して、指定された Maximum Value 列の値が以前に見た最大値よりも大きいすべての行を取得します。

QueryDatabaseTableRecord

SQL select クエリを生成するか、提供されたステートメントを使用し、それを実行して、指定された Maximum Value 列の値が以前に見た最大値よりも大きいすべての行を取得します。

Snowflake

QueryMilvus

ベクトルを使用して、Milvus データベースの指定されたコレクションをクエリします。

Snowflake

QueryPinecone

入力ベクトルと似ているベクトルを Pinecone にクエリするか、 ID によってベクトルを取得します。

QueryRecord

FlowFile のコンテンツに対して、1 つ以上の SQL クエリを評価します。

QuerySalesforceObject

Salesforce sObject から記録を取得します。

QuerySplunkIndexingStatus

インデックス確認のステータスを取得するために Splunk サーバーにクエリを発行します。

R

プロセッサー

説明

RemoveRecordField

FlowFile の記録指向データを含むコンテナーのコンテンツを変更します。(i.

RenameRecordField

FlowFile の各記録の 1 つ以上のフィールド名を変更します。

ReplaceText

FlowFile 内のテキスト値を (正規表現/正規表現、またはリテラル値で) 検索し、マッチした部分を代替値で置き換えることで、 FlowFile のコンテンツを更新します。

ReplaceTextWithMapping

正規表現を使って FlowFile のコンテンツを更新し、正規表現にマッチする部分をマッピングファイルで指定された代替値で置き換えます。

RetryFlowFile

このプロセッサーに渡される FlowFiles の 'Retry Attribute' の値は、構成された 'Maximum Retries' 値と照合されます。

RouteOnAttribute

Attribute Expression Language(属性式言語)を使用して、属性に基づいて FlowFiles をルーティングします。

RouteOnContent

FlowFile のコンテンツに正規表現を適用し、正規表現が一致する各宛先に FlowFile のコピーをルーティングします。

RouteText

ユーザー定義のルールセットに基づいてテキストデータをルーティングします。

Snowflake

RunDatabricksJob

事前に定義された Databricks ジョブをカスタムパラメーターで実行するトリガーです。

RunMongoAggregation

フローファイルを受信するたびに集約クエリを実行するプロセッサー。

S

プロセッサー

説明

SampleRecord

指定されたサンプリング戦略(貯水池サンプリングなど)に基づき、 FlowFile の記録をサンプルします。

ScanAttribute

FlowFiles の指定された属性をスキャンし、その値が指定された用語辞書内に存在するかどうかをチェックします。

ScanContent

FlowFiles のコンテンツを、ユーザーが用意した辞書にある用語でスキャンします。

ScriptedFilterRecord

このプロセッサーは、ユーザーが用意したスクリプトを使用して、 FlowFiles から記録をフィルターする機能を提供します。

ScriptedPartitionRecord

記録指向のデータを受信 (i.

ScriptedTransformRecord

受信 FlowFile の各記録に対して簡単なスクリプトを評価する機能を提供します。

ScriptedValidateRecord

このプロセッサーは、ユーザー提供のスクリプトを使用して FlowFiles の記録を検証する機能を提供します。

SearchElasticsearch

Elasticsearch JSON DSL で記述されたページ分割されたクエリ(集約を含む)を繰り返し実行できるプロセッサーです。

SegmentContent

FlowFile をバイト境界で複数の小さなセグメントに分割します。

SignContentPGP

OpenPGP プライベートキーを使用してコンテンツに署名します。

Snowflake

SnowflakeDetectDuplicate

FlowFile のハッシュ (FlowFile 属性として提供) が既に Snowflake テーブルにあるかどうかをチェックし、 FlowFile が見つかった場合は 'duplicate'、見つからなかった場合は 'distinct'、エラーの場合は 'failure' にルーティングします。

SplitAvro

バイナリ符号化された Avro データファイルを、構成された出力サイズに基づいて小さなファイルに分割します。

SplitContent

受信した FlowFiles を指定したバイト列で分割します。

SplitExcel

このプロセッサーは、複数シートのMicrosoft Excelスプレッドシートを複数のMicrosoft Excelスプレッドシートに分割し、元のファイルの各シートを独自のフローファイルの個々のスプレッドシートに変換します。

SplitJson

JsonPath 式で指定された配列要素に対して、 JSON ファイルを複数の別々の FlowFiles に分割します。

SplitRecord

記録指向のデータ形式である入力 FlowFile を、複数の小さな FlowFiles データに分割します。

SplitText

最大行数またはフラグメントの合計サイズによって制限された行バウンダリで、テキストファイルを複数の小さなテキストファイルに分割します。

SplitXml

XML ファイルを複数の別々の FlowFiles に分割し、それぞれを元のルート要素の子または子孫で構成します。

StartAwsPollyJob

AWS Pollyジョブをトリガーします。

StartAwsTextractJob

AWS Textract ジョブをトリガーします。

StartAwsTranscribeJob

AWS Transcribe ジョブをトリガーします。

StartAwsTranslateJob

AWS Translate ジョブをトリガーします。

StartGcpVisionAnnotateFilesOperation

ファイル入力でVision演算子をトリガーします。

StartGcpVisionAnnotateImagesOperation

画像入力でVision演算子をトリガーします。

Snowflake

SubmitQueryJob

Bulk API 2. クエリジョブを Salesforce に送信します。

Snowflake

SummarizeText

このプロセッサーは、大容量言語モデル (LLM) を使用して、 FlowFile のコンテンツを要約します。

T

プロセッサー

説明

TagS3Object

Amazon S3 オブジェクトにタグを追加または更新します。

TailFile

ファイルまたはファイルのリストを "テール "し、ファイルに書き込まれたデータをファイルから取り込みます。

TransformXml

プロバイダーの XSLT ファイルを FlowFile XML ペイロードに適用します。

U

プロセッサー

説明

UnpackContent

いくつかの異なるパッケージング形式のいずれかでパッケージ化された FlowFiles のコンテンツを解凍し、入力 FlowFile ごとに 1 つから多数の FlowFiles を生成します。

UpdateAttribute

属性式言語を使用して FlowFile の属性を更新、および/または正規表現に基づいて属性を削除します。

UpdateBoxFileMetadataInstance

指定された flowFile の記録を使用して、Box ファイルのメタデータ Template 値を更新します。

UpdateByQueryElasticsearch

クエリを使用して Elasticsearch インデックスのドキュメントを更新します。

UpdateCounter

このプロセッサーにより、ユーザーは特定のカウンターやフローのキーポイントをセットすることができます。

UpdateDatabaseTable

このプロセッサーは、 JDBC 接続と受信記録を使用して、受信記録をサポートするために必要なデータベーステーブルの変更を生成します。

UpdateRecord

記録指向のデータ を含む FlowFile のコンテンツを更新します。(i.

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

FlowFiles のコンテンツを、構成可能な JSON スキーマに対して検証します。

ValidateRecord

入力された FlowFile の記録を、指定されたスキーマに照らして検証します。

ValidateXml

FlowFile に含まれる XML を検証します。

VerifyContentMAC

提供された秘密キーを使ってメッセージ認証コードを計算し、提供された MAC プロパティと比較します。

VerifyContentPGP

OpenPGP 公開キーを使用した署名の検証

W

プロセッサー

説明

待機

対応するNotifyプロセッサーからのリリース信号が分散キャッシュに格納されるまで、入ってくる FlowFiles を「wait」関係にルーティングします。

Snowflake

WaitForTableState

対応するテーブルのステートがacceptedステートに等しくなくなるまで、 FlowFiles の着信をブロックします。