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

このトピックでは、すべての 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 の着信をブロックします。