PutSnowflakeInternalStageFile
Description
Puts files into a Snowflake internal stage. The internal stage must be created in the Snowflake account beforehand.
Tags
connection, database, jdbc, snowflake, snowpipe
Properties
In the list below required Properties are shown with an asterisk (*). Other properties 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 Service * | Snowflake Connection Service | Controller Service: DBCPService Implementations: DBCPConnectionPoolLookup DBCPConnectionPool HikariCPConnectionPool SnowflakeConnectionService | Database Connection Service for accessing 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, using Environment variables. This property is only considered if:
| ||
Schema | Schema | The schema to use by default. The same as passing 'schema=SCHEMA' to the connection string. Supports Expression Language, using Environment variables. This property is only considered if:
| ||
Table * | Table | The name of the table in the Snowflake account. Supports Expression Language, using FlowFile attributes and Environment variables. This property is only considered if:
| ||
Stage * | Stage | The name of the internal stage in the Snowflake account to put files into. Supports Expression Language, using FlowFile attributes and Environment variables. This property is only considered if:
| ||
File Prefix | File Prefix | Path prefix under which the data should be uploaded on the stage. Supports Expression Language, using FlowFile attributes and Environment variables. | ||
File Name * | File Name | ${filename} | Destination file name to use. Supports Expression Language, using FlowFile attributes and Environment variables. | |
Compression Enabled | Compression Enabled | false |
| Set true to compress data before uploading the file |
Dynamic Properties
This component does not support dynamic properties.
Relationships
Name | Description |
---|---|
failure | For FlowFiles of failed PUT operation |
success | For FlowFiles of successful PUT operation |
Reads Attributes
This processor does not read attributes.
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
This component does not specify system resource considerations.