Mam funkcję LAMBDA Running Node.js Funkcja sprawia, że baza danych połączenia i wysyła wiadomość tekstową przez SNS. Ma następującą strukturę

enter image description here

Funkcje -> plik index.js wygląda tak

async function sendTextMessage(message, phoneNumber) {
  try {
    console.log("hitSendFunction");
    const sns = new AWS.SNS();

    const params = {
      Message: message,
      MessageStructure: "string",
      PhoneNumber: phoneNumber
    };
    //remember phone number must have +1 before it.

    return await sns.publish(params).promise();
  } catch (error) {
    console.log(error);
  }
}
module.exports = {
  sendTextMessage
};

Ta funkcja jest nazywana w głównym pliku index.js:

const database = require("./db");
const { sendTextMessage } = require("./functions");
const AWS = require("aws-sdk");
AWS.config.region = "us-east-1";
exports.handler = async function (event, context) {
  try {
    console.log("hit");
    const result = await database.query("call getTicker()");
    const data = result[0][0];
    const currentProjectEndDate = new Date(
      data.currentProjectEndDate
    ).getTime();
    const now = new Date().getTime();
    console.log("data.currentProjectEndDate", data.currentProjectEndDate);
    const runningHot =
      data.jobsInQueue > 0 && currentProjectEndDate <= now && data.textSent < 1;
    if (runningHot) {
      const numbers = ["+1435994****"];
      for (let i = 0; i < numbers.length; i++) {
        let number = numbers[i];
        console.log("number", number);
        let messageResult = await sendTextMessage(
          "The CE Bot is running hot from lambda",
          number
        );
        console.log("messageResult", messageResult);
      }
      await database.query("call insertIntoTextSent()");
      console.log("yes");
    }
  } catch (error) {
    console.log("this was the error", error);
  }

Wywołania bazy danych działa poprawnie, ale funkcja tekstowa po prostu zawiesza się i razy. Funkcja LAMBDA ma następujące uprawnienia dołączone do niego:

enter image description here

Wreszcie mimo że nie sądzę, że jest potrzebny, ponieważ pracuje tutaj kod DB, jest tym, jak wygląda plik DB -> index.js:

const mysql = require("mysql");
const util = require("util");

const awsConfig = {
  host: process.env.RDS_HOST,
  user: process.env.RDS_USER,
  password: process.env.RDS_PASSWORD,
  database: process.env.RDS_DATABASE
};

const connection = mysql.createConnection(awsConfig);

connection.query = util.promisify(connection.query.bind(connection));
connection.end = util.promisify(connection.end.bind(connection));

module.exports = connection;

Nie jestem pewien, gdzie tu idę źle. Czy ktoś może skierować mnie we właściwym kierunku?

0
codernoob8 7 październik 2020, 18:57

1 odpowiedź

Najlepsza odpowiedź

Możesz po prostu wysłać go za pośrednictwem SMS w SNS, po prostu wpisz numer telefonu

0
codernoob8 2 listopad 2020, 21:51