auths
objectreturn
or this.key = 'value'
, pass input data to your code viaparams
, and maintain state across executions with$checkpoint.async
(event, steps) => {
}
const {
SNOWFLAKE_USERNAME,
SNOWFLAKE_ACCOUNT_NAME,
SNOWFLAKE_DATABASE,
SNOWFLAKE_SCHEMA,
SNOWFLAKE_ROLE,
SNOWFLAKE_STAGE,
SNOWFLAKE_PIPE,
SNOWFLAKE_PRIVATE_KEY,
} = process.env
if (!SNOWFLAKE_USERNAME) {
$end("No SNOWFLAKE_USERNAME environment variable defined")
}
if (!SNOWFLAKE_ACCOUNT_NAME) {
$end("No SNOWFLAKE_ACCOUNT_NAME environment variable defined")
}
if (!SNOWFLAKE_DATABASE) {
$end("No SNOWFLAKE_DATABASE environment variable defined")
}
if (!SNOWFLAKE_SCHEMA) {
$end("No SNOWFLAKE_SCHEMA environment variable defined")
}
if (!SNOWFLAKE_ROLE) {
$end("No SNOWFLAKE_ROLE environment variable defined")
}
if (!SNOWFLAKE_STAGE) {
$end("No SNOWFLAKE_STAGE environment variable defined")
}
if (!SNOWFLAKE_PIPE) {
$end("No SNOWFLAKE_PIPE environment variable defined")
}
if (!SNOWFLAKE_PRIVATE_KEY) {
$end("No SNOWFLAKE_PRIVATE_KEY environment variable defined")
}
$send.snowflake({
user: SNOWFLAKE_USERNAME,
private_key: SNOWFLAKE_PRIVATE_KEY,
database: SNOWFLAKE_DATABASE,
schema: SNOWFLAKE_SCHEMA,
stage_name: SNOWFLAKE_STAGE,
pipe_name: SNOWFLAKE_PIPE,
account: SNOWFLAKE_ACCOUNT_NAME,
host: `${SNOWFLAKE_ACCOUNT_NAME}.snowflakecomputing.com`,
payload: $event,
})