execute-aws-athena-query.js

exports.handler = (event, context, callback) => {
    var AWS = require('aws-sdk');
    AWS.config.update({region: 'eu-west-1'}); // configure region
    const athena = new AWS.Athena();
    
    athena.getNamedQuery({ NamedQueryId: '<your-query-id>' }, function(err, data) {
        console.log('getNamedQuery', err, data);
        if (!err) {
            var params = {
              QueryString: data.NamedQuery.QueryString,
              ResultConfiguration: {
                OutputLocation: 's3://<your-bucket-name>/<folder>',
              },
              QueryExecutionContext: {
                Database: 'segment'
              }
            };
            athena.startQueryExecution(params, function(err, data) {
              console.log('startQueryExecution', err, data);
              if (err) {
                callback(err);
              } else {
                callback(null, 'query started');
              }
            });
        } else {
            callback(err);
        }
    });
    
};