Description:
Puts files into a Snowflake internal stage. The internal stage must be created in the Snowflake account beforehand. This processor can be connected to a StartSnowflakeIngest processor to ingest the file in the internal stage
Additional Details...
Tags:
snowflake, jdbc, database, connection, snowpipe
Properties:
In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.
| Display Name | API Name | Default Value | Allowable Values | Description |
|---|
| Snowflake Connection Provider | snowflake-connection-provider | | Controller Service API:
SnowflakeConnectionProviderService
Implementation: SnowflakeComputingConnectionPool | Specifies the Controller Service to use for creating SQL connections to Snowflake. |
| Internal Stage Type | internal-stage-type | | | The type of internal stage to use |
| Database | database | | | The database to use by default. The same as passing 'db=DATABASE_NAME' to the connection string.
Supports Expression Language: true (will be evaluated using Environment variables only)
This Property is only considered if the [Internal Stage Type] Property is set to one of the following values: [Named], [Table] |
| Schema | schema | | | The schema to use by default. The same as passing 'schema=SCHEMA' to the connection string.
Supports Expression Language: true (will be evaluated using Environment variables only)
This Property is only considered if the [Internal Stage Type] Property is set to one of the following values: [Named], [Table] |
| Table | table | | | The name of the table in the Snowflake account.
Supports Expression Language: true (will be evaluated using flow file attributes and Environment variables)
This Property is only considered if the [Internal Stage Type] Property has a value of "Table". |
| Stage | internal-stage | | | The name of the internal stage in the Snowflake account to put files into.
Supports Expression Language: true (will be evaluated using flow file attributes and Environment variables)
This Property is only considered if the [Internal Stage Type] Property has a value of "Named". |
Relationships:
| Name | Description |
|---|
| failure | For FlowFiles of failed PUT operation |
| success | For FlowFiles of successful PUT operation |
Reads Attributes:
None specified.Writes Attributes:
| Name | Description |
|---|
| snowflake.staged.file.path | Staged file path |
State management:
This component does not store state.Restricted:
This component is not restricted.Input requirement:
This component requires an incoming relationship.System Resource Considerations:
None specified.See Also:
StartSnowflakeIngest, GetSnowflakeIngestStatus
