Snowflake
27 min
learn how to connect engini to snowflake using engini’s snowflake activities, you can retrieve and manage data, execute sql statements, explore databases, schemas, and tables, and integrate snowflake with other applications directly through your engini workflows to get started with the snowflake connector, make sure you have access to an active snowflake account and the required authentication credentials and permissions getting started with snowflake prerequisites an active snowflake account/environment the required authentication credentials and permissions to access the relevant warehouses, databases, schemas, and tables connecting engini to snowflake add a connection to snowflake in engini enter your engini account at https //app engini io https //app engini io/ navigate to connections page by clicking on the connections on the left sidebar or by clicking here https //app engini io/connections click on the "new integration" option located at the top bar choose snowflake option from the available applications enter the following details in the “new integration” form and press save connection name enter a clear name to identify this snowflake connection in engini this name will help distinguish it from other connections configured for the same integration base url displays the base url used for the snowflake connection this value defines the endpoint engini will use when communicating with snowflake client id enter the client id provided for your snowflake oauth application it is used together with the client secret to authenticate the connection client secret enter the client secret associated with the oauth application this value is used securely during the authentication process account identifier enter the unique identifier of your snowflake account this value is required so engini can connect to the correct snowflake environment advanced settings expand this section to view and configure additional connection options when needed signin click signin after entering the required connection details engini will use the provided credentials to authenticate with snowflake save click save to store the connection configuration after the authentication process is completed triggers new row triggers when a new row is added to a selected snowflake table, allowing the workflow to continue with the newly created row data scheduled query runs a predefined snowflake query automatically according to a configured schedule and returns the query results updated row triggers when an existing row is updated in a selected snowflake table and provides the updated row data to the workflow actions create database creates a new database in snowflake using the specified database name and configuration name enter the name of the new snowflake database you want to create add field click add field to add and populate additional fields for the selected activity to learn more about managing activity data, click here https //help engini ai/workflow editor#add fields create row adds a new row to a selected snowflake table using the field values provided in the action database select the snowflake database you want to work with the selected database determines the available options in the following warehouse and role fields warehouse select the snowflake warehouse that will be used to execute the operation the warehouse provides the compute resources required to process the request role select the snowflake role to use for the operation the selected role determines the permissions and access available when interacting with the database create schema creates a new schema inside a selected snowflake database for organizing tables and other database objects database select the snowflake database in which you want to create the new schema after selecting a database, the relevant schema configuration fields will become available for defining the new schema create table creates a new table inside a selected snowflake schema using the defined table structure and fields database select the snowflake database in which you want to create the new table after selecting a database, the relevant schemas and additional table configuration fields will become available for defining where and how the table should be created delete database deletes an existing snowflake database and removes the database according to the provided configuration name select the snowflake database you want to delete the field automatically retrieves the databases associated with the connected snowflake account, allowing you to choose the relevant database from the available options delete row deletes a specific row from a selected snowflake table based on the provided row identifier or conditions database select the snowflake database that contains the row you want to delete after selecting a database, the relevant objects and fields required to identify the target row become available warehouse select the snowflake warehouse that will execute the delete operation the warehouse provides the compute resources required to run the command role select the snowflake role that will be used for the operation the selected role determines the permissions available for accessing the database and deleting the relevant row delete schema deletes an existing schema from a snowflake database according to the specified configuration database select the snowflake database that contains the schema you want to delete after selecting a database, the relevant schemas associated with that database will become available for selection delete table deletes an existing table from a selected snowflake schema database select the snowflake database that contains the table you want to delete after selecting a database, the relevant schemas and tables associated with that database will become available for selection get database retrieves detailed information about a specific snowflake database, including its available metadata and properties name select the snowflake database you want to retrieve the field automatically loads the databases associated with the connected snowflake account, allowing you to choose the relevant database and retrieve its details get databases retrieves a list of snowflake databases available to the connected account and role top n enter the maximum number of databases to return if no value is provided, the action retrieves all available databases add filter click add filter to define conditions that narrow down the data list and return only the relevant items to learn more about using filters, click here https //help engini ai/workflow editor#add filters get roles retrieves the snowflake roles available to the connected account for use in queries and operations get row retrieves a specific row from a selected snowflake table based on the provided identifier or conditions database select the snowflake database you want to work with after a database is selected, additional fields become available so you can continue defining the specific data source and query context warehouse enter or select the snowflake warehouse that should be used to execute the query the warehouse provides the compute resources required for the operation role enter or select the snowflake role that should be used for the request the selected role determines which databases, schemas, tables, and other resources the connection is allowed to access get rows retrieves multiple rows from a selected snowflake table based on the configured query, filters, or limits database select the snowflake database from which you want to retrieve rows after selecting a database, additional fields become available so you can continue defining the schema, table, and query settings warehouse select or enter the snowflake warehouse that should execute the query the warehouse provides the compute resources required to retrieve the requested rows role select or enter the snowflake role to use for the request the selected role determines which databases, schemas, tables, and rows the connection is authorized to access get schema retrieves detailed information about a specific schema within a selected snowflake database database select the snowflake database whose schemas you want to retrieve the action will return the schemas available in the selected database according to the permissions of the configured connection get schemas retrieves a list of schemas available within a selected snowflake database database select the snowflake database whose schemas you want to retrieve the action returns the schemas available in the selected database according to the permissions of the configured connection get table retrieves detailed information and metadata about a specific table in a snowflake schema database select the snowflake database that contains the table you want to retrieve after selecting the database, additional fields become available so you can continue selecting the relevant schema and table get tables retrieves a list of tables available within a selected snowflake database or schema database select the snowflake database whose tables you want to retrieve after selecting the database, additional fields may become available so you can further narrow the request, such as by schema or other table related settings get warehouses retrieves a list of snowflake warehouses available to the connected account and role update database updates supported properties or configuration of an existing snowflake database name enter the name of the snowflake database you want to update this value identifies the existing database that the action should modify add field click add field to add and populate additional fields for the selected activity to learn more about managing activity data, click here https //help engini ai/workflow editor#add fields update row updates the values of an existing row in a selected snowflake table using the provided fields and conditions database select the snowflake database that contains the row you want to update after selecting the database, additional fields become available so you can continue defining the schema, table, and row to update warehouse select or enter the snowflake warehouse that should execute the update operation the warehouse provides the compute resources required to process the request role select or enter the snowflake role to use for the update the selected role determines whether the connection has permission to access and modify the relevant database objects update schema updates supported properties or configuration of an existing schema in snowflake database select the snowflake database that contains the schema you want to update after selecting the database, additional fields become available so you can choose the relevant schema and define the properties that should be updated update table updates supported properties or configuration of an existing snowflake table database select the snowflake database that contains the table you want to update after selecting the database, additional fields become available so you can choose the relevant schema and table and define the properties that should be updated run custom sql executes a custom sql statement in snowflake, allowing you to run queries or other supported sql commands and receive the result add field click add field to add and populate additional fields for the selected activity to learn more about managing activity data, click here https //help engini ai/workflow editor#add fields send api request sends a custom request to the snowflake api using the existing connection, allowing access to operations not covered by the predefined actions base url the main endpoint of the api you want to call (e g , the server or service url) relative url the specific path or resource you want to access, appended to the base url method defines the http method used for the request (e g , get, post, put, delete) body type specifies the format of the request body (e g , json, form data) application/json – sends the request body in json format commonly used by rest apis application/json – sends the request body in json format commonly used by rest apis custom (use content type header) – allows you to define a custom body format by manually setting the content type header application/x www form urlencoded – sends the body as url encoded key value pairs, commonly used in form submissions file – sends a file as the request body multipart/form data – sends form data that may include both text fields and files text/html – sends the request body as html content text/plain – sends the request body as plain text text/xml – sends the request body in xml format body the payload sent with the request, usually required for methods like post or put add headers allows you to include additional headers (e g , authorization, content type) required by the api add queries allows you to add query parameters to the request url (e g , filters, pagination)