Get live logs from AWS CloudWatch

cloudwatch-get-logs.js

var AWS = require("aws-sdk");
AWS.config.update({
  region: "us-west-2",
});

const {
  CloudWatchLogsClient,
  AssociateKmsKeyCommand,
  StartQueryCommand,
  GetQueryResultsCommand,
} = require("@aws-sdk/client-cloudwatch-logs");
var dayjs = require("dayjs");

// Create CloudWatch service object
var cw = new AWS.CloudWatch({
  apiVersion: "2010-08-01",
});

let currentQueryId = "";
const client = new CloudWatchLogsClient({ region: "us-west-2" });
async function startQuery() {
  const params = {
    startTime: dayjs("2022-01-20").unix(),
    endTime: dayjs().unix(),
    logGroupNames: ["GROUP_NAME"],
    queryString: `
      fields @timestamp, @message
      | sort @timestamp desc
      | limit 20
      `,
  };
  const cmd = new StartQueryCommand(params);
  // console.log(cmd);
  const response = await client.send(cmd);
  // console.log(response);
  return response;
}

async function getQueryResults(queryId) {
  const results = new GetQueryResultsCommand({
    queryId: queryId,
  });
  const resultsResponse = await client.send(results);
  if (resultsResponse.results[0]) {
    currentQueryId = queryId;
    console.log(
      resultsResponse.results[0].find((x) => x.field === "@timestamp").value
    );
    console.log(
      resultsResponse.results[0].find((x) => x.field === "@message").value
    );
  } else console.log("No results found");
}

setInterval(async () => {
  const { queryId } = await startQuery();
  console.log(queryId);

  setInterval(async () => {
    if (currentQueryId !== queryId) getQueryResults(queryId);
  }, 1000);
}, 10000);