主要流程#xff1a;

1.上传消息到s3存储桶#xff08;不做具体描述#xff09;

2.通过aws的lambda监听s3存储桶的最新消息#xff08;txt文件#xff09;

3.将txt文件…业务描述

需要监听aws的存储中的最新消息发送新的消息推送到指定tg的频道。

主要流程

2.通过aws的lambda监听s3存储桶的最新消息txt文件

具体流程

代码源中必须包含package和node_modules,需要项目的完整环境

代码如下可以根据自己的业务调整。

我的业务tg频道的channel

在lambda中发送完消息之后是无法获取状态的也就是代码中response是没法获取状态的不管成功失败。

这也就导致了会存在消息丢失的情况

const

require(node-telegram-bot-api);

const

TelegramBot(TELEGRAM_BOT_TOKEN);//

AWS

decodeURIComponent(record.s3.object.key.replace(/\/g,

));

eventName.startsWith(ObjectCreated:Put))

{console.log(New

(key.startsWith(${TEXT_NAME}/))

{//

打印更新文件的名称console.log(textContent:

${textContent});//

获取发送到的频道的idconsole.log(channelId:,

channelId);const

lines.slice(3).join(\n).trim();

else

key.split(/).pop().split(.).slice(0,

name

{allImage.push(${fileName}.img${index}.jpg);}console.log(All

images:

https://${bucket}.s3.us-east-1.amazonaws.com/${MEDIA_NAME}/${image});//

发送所有图片作为一条消息await

sendPhotosToTelegram(imageUrls,

captionContent,

s3.headObject(params).promise();return

metadata;

s3.getObject(params).promise();return

};const

captionContent;media[0].parse_mode

Markdown;

//注意此处的选择Markdown是支持多图和超链接文本的但是MarkdownV2是不支持超链接文本的而且也不支持特殊字符}try

{console.log(requeststart);const

response

bot.sendMediaGroup(${channelId},

media);console.log(requestend);console.log(Response

from

1.在没有解决消息丢失的情况下建议不要使用lambda推送重要消息

2.可以使用mq来完成消息的监听和发送这样response也可以监听到状态也不会存在消息丢失情况即使丢失也可以通过状态控制。