auths
objectreturn
or this.key = 'value'
, pass input data to your code viaparams
, and maintain state across executions with$checkpoint.async
(event, steps) => {
}
//first, create the sql payload and set the timestamp to the time the event was received
$event.sqlPayload = {}
$event.sqlPayload.timestamp = $context.ts
//next, parse the url and assign the button name to a $event field
var url = require('url');
var url_parts = url.parse($event.url, true);
var query = url_parts.query;
if(query.button) {
$event.sqlPayload.button = query.button
} else {
$event.sqlPayload.button = "Unknown"
}
//next we'll save $event.sqlPayload to Pipedream's SQL service so we can query the data