Configure your source processor

You can use ListDatabaseTable to get data from your Snowflake table. To do this, launch the Configure Processor window, specify the necessary configurations, and start the process to verify that you can view the Snowflake table.

Use the ListDatabaseTables Processor to get data from Snowflake database tables.

Set the proper Scheduling Strategy on the processor in accordance with your use case. You use this Processor to list the tables available in the remote database. You can update the value of the Refresh Interval property in combination with the Scheduling Strategy to determine at which frequency tables will be listed.

Configure this Processor to run only on the primary node of your NiFi cluster.

You have built the dataflow.
You have created your Controller Services.

Launch the Configure Process window, by right-clicking the Processor and selecting Configure.
Configure ListDatabaseTables according to your use case and operational objectives.
Configure Database Connection Pooling Service to call the database connection Controller Service you created in the preceeding step.
You can use the Scheduling Strategy and the Refresh Interval configuration properties to determine how frequently the tables will be listed in the Snowflake database.
Use the Table Name Pattern value to specify whether you want to pull all the tables or just some.

If you want just some, define a regular expression. If the property value is not set, all tables are retrieved.

You can confirm that you have configured ListDatabaseTables correctly by starting the Processor and confirming that you can view the Snowflake table.

After you have finished configuring your source Processor, proceed to:

Configure your target Processor
Confirm your dataflow is running