Serverless Telegram
这是官方无服务器项目列表中另一个有趣的项目。我们基本上在 Telegram 上创建了一个新机器人，然后使用 set_webhook 方法将它连接到我们的 lambda 函数，并在 lambda 函数中编写代码，让机器人回显收到的任何消息。
先决条件
您需要在手机或台式机上安装 Telegram 应用程序。可以在此处找到下载选项。 Telegram 是一个消息应用程序，有点类似于 WhatsApp 或 Messenger。安装应用程序后，您需要在应用程序中创建一个新机器人。为此，单击"新消息"图标（右下角的圆形铅笔图标），然后搜索 BotFather。点击经过验证的帐户。
一旦您开始与 BotFather 聊天，创建一个新的机器人就变得一目了然。您发送
\newbot 命令，输入机器人的名称和用户名，您将获得一个访问令牌，您需要记下该令牌。
代码演练
代码可以在 GitHub 上找到-https://github.com/serverless/examples/tree/master/aws-python-telegram-bot
我们将查看项目结构，然后执行 serverless.yml 文件和 handler.py 文件的演练。
项目结构
我们可以看到这个项目有一个外部依赖（python 电报机器人库），列在 requirements.py 中-
python-telegram-bot==8.1.1
package.json 和 serverless.yml 都表明 serverless-python-requirements 插件已用于捆绑 python 需求（在这种情况下是电报机器人库）。因此，README.md 文件也表明你执行
npm install 来安装必要的插件。我个人建议您删除 package.json，并使用
sls plugin install-n serverless-python-requirements 安装 serverless-python-requirements。这将自动创建 package.json 文件。这还将确保您安装最新版本的 serverless-python-requirements。通过运行
npm install，您将安装现有 package.json 中提到的版本，该版本可能已过时。
如果您阅读 README.md 文件，您会发现引用的一个文件实际上并不存在于项目中-serverless.env.yml。您被要求创建此文件并在此文件中输入您的 TELEGRAM_TOKEN。这样做是出于安全原因。 TELEGRAM_TOKEN 应该是机密的，您不想公开共享。因此，该项目的创建者并未在 GitHub 上添加 serverless.env.yml 文件。但是您需要在本地计算机上创建它。
serverless.yml 演练
serverless.yml 文件以服务的定义开始。
service: serverless-telegram-bot
接下来，定义提供者。这里再次设置了一个环境变量。此变量 (TELEGRAM_TOKEN) 的值是从应该在本地创建的 serverless.env.yml 文件中获取的。在这里，我们再次使用
$ 来表示变量。
provider:
name: aws
runtime: python3.6
profile: ckl
environment:
TELEGRAM_TOKEN: ${file(./serverless.env.yml):TELEGRAM_TOKEN, ''}
功能块非常简单。定义了两个函数，都是 HTTP 触发的。但是，http 事件参数在此处定义在一行中。
-http:
path: /set_webhook
method: post
代替单行执行的是
-http-
POST/set_webhook
另外，请注意
webhook 和
set_webhook 函数位于同一个处理程序文件中。
functions:
webhook:
handler: handler.webhook
events:
-http: POST /
set_webhook:
handler: handler.set_webhook
events:
-http: POST /set_webhook
最后，定义了 serverless-python-requirements 插件。
plugins:
-serverless-python-requirements
handler.py 演练
我们有几个导入语句
import json
import telegram
import os
import logging
接下来定义一个logger对象，基本帮助我们输入日志语句。请注意，这对于 python 运行时函数不是必需的。简单的打印语句也会被记录。
唯一的区别是 logger 的输出包括日志级别、时间戳和请求 ID。您可以在此处阅读有关日志记录库的更多信息。
# Logging is cool!
logger = logging.getLogger()
if logger.handlers:
for handler in logger.handlers:
logger.removeHandler(handler)
logging.basicConfig(level=logging.INFO)
接下来，定义 OK_RESPONSE 和 ERROR_RESPONSE 的 JSON。这些用作函数的返回值。
OK_RESPONSE = {
'statusCode': 200,
'headers': {'Content-Type': 'application/json'},
'body': json.dumps('ok')
}
ERROR_RESPONSE = {
'statusCode': 400,
'body': json.dumps('Oops, something went wrong!')
}
接下来，定义了两个 API 函数都使用的辅助函数。此函数使用 serverless.yml 中作为环境变量提供的 Token 返回一个机器人实例。
def configure_telegram():
"""
Conimages the bot with a Telegram Token.
Returns a bot instance.
"""
TELEGRAM_TOKEN = os.environ.get('TELEGRAM_TOKEN')
if not TELEGRAM_TOKEN:
logger.error('The TELEGRAM_TOKEN must be set')
raise NotImplementedError
return telegram.Bot(TELEGRAM_TOKEN)
接下来，定义两个 API 的处理函数。我们先来看看
set_webhook 函数。在这里，bot 实例是从我们之前看到的 configure_telegram 函数中获取的。接下来，从头中提取主机字段，从传入事件的 requestContext 块中提取 stage 字段。使用这两个字段，构建 webhook 的 URL。最后，它使用
bot.set_webhook(url) 函数应用于机器人。如果 webhook 设置正确，则设置 OK_RESPONSE，否则设置 ERROR_RESPONSE。请注意，此 set_webhook API 必须使用 POSTMAN 之类的工具手动触发一次。
def set_webhook(event, context):
"""
Sets the Telegram bot webhook.
"""
logger.info('Event: {}'.format(event))
bot = configure_telegram()
url = 'https://{}/{}/'.format(
event.get('headers').get('Host'),
event.get('requestContext').get('stage'),
)
webhook = bot.set_webhook(url)
if webhook:
return OK_RESPONSE
return ERROR_RESPONSE
让我们了解 set_webhook 函数如何能够获取 webhook 的正确 URL。请注意，set_webhook 和 webhook 函数在它们的路径中只有 '/set_webhook' 的区别。他们共享同一个主持人和舞台。因此，我们可以使用在 set_webhook 函数的事件中接收到的 host 和 dev 来导出 webhook 函数的端点。如果您的端点是"https://abcdefghijk.execute-api.us-east-1.amazonaws.com/dev"，则主机将为"https://abcdefghijk.execute-api.us-east-1"。 amazonaws.com"，舞台将是"dev"。 set_webhook 函数由"https://abcdefghijk.execute-api.us-east-1.amazonaws.com/dev/set_webhook"触发，webhook 函数由"https://abcdefghijk.execute-api.us"触发-east-1.amazonaws.com/dev'。因此，set_webhook 事件中的参数可以帮助我们构造 webhook 函数的端点 URL。
最后，我们来看一下 webhook 功能。这很简单。它从
configure_telegram 辅助函数接收机器人实例。然后它检查事件。如果它是一个 POST 事件并且包含一个正文，那么它会从正文中提取聊天 ID 和消息。如果文本是"/start"，表示对话开始，它会使用
bot.sendMessage(chat_id=chat_id, text=text) 命令回复标准问候语。否则，它会用收到的相同文本回复。
def webhook(event, context):
"""
Runs the Telegram webhook.
"""
bot = configure_telegram()
logger.info('Event: {}'.format(event))
if event.get('httpMethod') == 'POST' and event.get('body'):
logger.info('Message received')
update = telegram.Update.de_json(json.loads(event.get('body')), bot)
chat_id = update.message.chat.id
text = update.message.text
if text == '/start':
text = """Hello, human! I am an echo bot, built with Python and the Serverless Framework.
You can take a look at my source code here: https://github.com/jonatasbaldin/serverless-telegram-bot.
if you have any issues, please drop a tweet to my creator: https://twitter.com/jonatsbaldin. Happy botting!"""
bot.sendMessage(chat_id=chat_id, text=text)
logger.info('Message sent')
return OK_RESPONSE
return ERROR_RESPONSE
一旦您通过 POSTMAN 等工具触发了 set_webhook 功能，您就可以在 Telegram 上打开您的机器人并与其聊天。它将按预期回显消息。
祝贺你的第一个 Telegram 机器人！
