auths
objectreturn
or this.key = 'value'
, pass input data to your code viaparams
, and maintain state across executions with$checkpoint.async
(event, steps, auths) => {
}
const {
user,
private_key,
database,
schema,
stage_name,
pipe_name,
account,
host,
} = auths.snowflake
// Send a test record to Snowflake. You can modify the payload
// field to send any data you'd like. For example, if you're using
// an HTTP trigger and want to send the request payload, use event.body
// See https://docs.pipedream.com/workflows/events/#event-format
$send.snowflake({
user,
private_key,
database,
schema,
stage_name,
pipe_name,
account,
host: `${account}.snowflakecomputing.com`,
payload: { test: "This is from Pipedream" }
})