通过SQS lambda发送SQS消息

Question

我有一个连接到lambda的种子指示符信息qs-dev.fifo队列（fifo）。我想在种子指示信息QS-dev-d13dfe0lambda中向评估配置SQS dev标准队列发送一条消息。但没有发送/接收任何消息。然而，如果我尝试从非SQS连接的lambda（通过AppSync）发送它，它会工作。

我查过：

• lambda有权发送SQS消息（您可以在那里看到）
• 由于我已成功地从另一个lambda（非SQS）向标准队列发送消息，因此正确配置了EvaluationConfigSQS dev标准队列
• SQS URL是否正确
• 控制台中不会显示任何错误
• async/await的位置正确（我试过使用和不使用它们）

以下是试图分派内容的SeedSignatorInformationSQS-dev-d13dfe0 lambda的CloudWatch日志：成功发送到正确的网址，JSON解析为字符串，但什么都没有。

这是CloudWatch日志：您可以看到<代码>种子指示信息QS-dev-d13dfe0成功地从另一个lambda函数接收消息并对其进行处理，但不会发送更多消息。

种子指示信息QS-dev-d13dfe0中未报告任何错误

以下是EvaluationConfigSQS-dev-6da8b90的权限（EvaluationConfigSQS dev标准队列触发的lambda）

这是被调度的JS（我使用了一个中介模式，它成功地被调度了，你可以在上面的“调度创建的机构类”日志中看到它）。我还打印了URL，并验证了它实际上是与之对应的URL。

export async function institutionClassCreatedEventHandler(
  evt: InstitutionClassCreatedEvent
) {
  const json = JSON.stringify({
    ...evt,
    type: "CLASS_CREATED",
  });


  sqsDispatchMessage(
    "InstitutionClassCreatedEvent",
    evt.tenantId + evt.subject.id,
    json,
    Config.SQS.evaluationConfigSQS.url,
    false
  );
}

这是sqsDispatchMessage函数。正如您所看到的，有一个catch块，每当出现错误时，它就会将我打印出来（并且可以正常工作）。但到目前为止，还没有记录到任何错误。

export async function sqsDispatchMessage(
  eventName: string,
  uniqueId: string,
  jsonObjStringifiedToSend: string,
  sqsURL: string,
  isFifoQueue: boolean = true
) {
  try {
    await sqs
      .sendMessage({
        MessageAttributes: {
          EventName: {
            DataType: "String",
            StringValue: eventName,
          },
        },
        ...(isFifoQueue && { MessageGroupId: eventName }),
        MessageBody: jsonObjStringifiedToSend,
        QueueUrl: sqsURL,
        ...(isFifoQueue && { MessageDeduplicationId: uniqueId }),
      })
      .promise();
  } catch (e) {
    console.error(`Error While Sending the ${eventName}`);
    console.error(e.message);
    console.log(jsonObjStringifiedToSend);
  }
}

有什么想法吗？这有可能吗？




Answer 1

问题出在我的调度员：

以前是这样的：

export async function dispatchOfEvents({
  type,
  evtArgs,
}: MediatorEvents): Promise<void> {
  logTime(type);
  (events as any)[type].forEach((evt: Function) => {
    evt(evtArgs);
  });
}

我把它改成：

export async function dispatchOfEvents({
  type,
  evtArgs,
}: MediatorEvents): Promise<void> {
  logTime(type);
  const evts: Promise<any>[] = [];
  for (const evt of (events as any)[type]) {
    evts.push(evt(evtArgs));
  }
  await Promise.all(evts);
}