in functions/source/tblcreate/tblcreate.js [63:103]
exports.handler = function(event, context) {
var config = {
host: event.ResourceProperties.host,
db: event.ResourceProperties.db,
user: event.ResourceProperties.user,
password: event.ResourceProperties.password,
port: event.ResourceProperties.port
};
if (event.RequestType == 'Create') {
var rssql = require('redshift-sql')(config);
var ctr = 'CREATE TABLE ctr (acw_end_tstamp TIMESTAMP, acw_start_tstamp TIMESTAMP, aws_account_id BIGINT NOT NULL, aws_ctr_format_ver VARCHAR(32), channel VARCHAR(255), conn_to_agent_tstamp TIMESTAMP, conn_to_ac_tstamp TIMESTAMP, contact_id VARCHAR(255), org_contact_id VARCHAR(255) distkey, ctr_init_tstamp TIMESTAMP, cust_addr_type VARCHAR(255), cust_addr_val VARCHAR(255), dequeue_tstamp TIMESTAMP, disc_tstamp TIMESTAMP sortkey, enqueue_tstamp TIMESTAMP, handle_attempts INTEGER, handled_by_agent VARCHAR(255), hold_dur INTEGER, init_tstamp TIMESTAMP, last_upd_tstamp TIMESTAMP, ac_addr_type VARCHAR(255), ac_addr_val VARCHAR(255), num_of_holds INTEGER, orig_contact_id VARCHAR(255), prev_contact_id VARCHAR(255), queue VARCHAR(255), rec_loc VARCHAR(255), tlk_duration INTEGER);';
var ctrattr = 'CREATE TABLE ctr_attr (aws_account_id BIGINT NOT NULL, org_id VARCHAR(255), contact_id VARCHAR(255) distkey, orig_contact_id VARCHAR(255), init_tstamp TIMESTAMP, disc_tstamp TIMESTAMP sortkey, last_upd_tstamp TIMESTAMP, attr_key VARCHAR(255), attr_val VARCHAR(255));';
rssql(ctr, function cb(err, result) {
if (err) {
console.error(err);
send(event, context, "FAILED");
} else {
console.log("Successfully created ctr table.")
console.log(result);
rssql(ctrattr, function cb(err, result) {
if (err) {
console.error(err);
send(event, context, "FAILED");
} else {
console.log("Successfully created ctr_attr table.")
console.log(result);
send(event, context, "SUCCESS");
}
});
}
});
} else if (event.RequestType == 'Update') {
send(event, context, "SUCCESS");
} else if (event.RequestType == 'Delete') {
send(event, context, "SUCCESS");
}
};