如何将通过 HTTP POST 从 Python Flask 脚本接收到的数据传递给单独的 Python 脚本进行处理？

Question

好的，伙计们，这是我的问题。

我正在开发一个带有打包机器人的 Slack 应用程序，允许用户在 Slack 中玩游戏。我已经按照API guidelines 成功构建了机器人并将其与应用程序打包在一起。当我发现Interactive Messages 功能后，我决定实现该功能，以使游戏更加用户友好。

交互式消息功能允许您使用按钮发布消息，用户可以单击这些按钮来调用操作。我的机器人脚本，我们称之为bot.py，提示用户（使用Slack chat.postMessage 函数）一条消息，其中包含一些可供选择的按钮。这个脚本有一个类（我知道它应该更加模块化，但一切都很好），它打开一个 web-socket 用于通过Slack RTM API 进行通信。因此，当脚本运行时，它总是“侦听”来自频道中用户的命令，引导如下：@botname command。调用这种“一直在听”状态的脚本部分如下所示：

#bot.py
...
if slack_client.rtm_connect():
        print("MYBOT v1.0 connected and running!")
        while True:
            command, channel, user = self.parse_slack_output(slack_client.rtm_read())
            if command and channel:
                if channel not in self.channel_ids_to_name.keys():
                    #this (most likely) means that this channel is a PM with the bot
                    self.handle_private_message(command, user)
                else:
                    self.handle_command(command, channel, user)
            time.sleep(READ_WEBSOCKET_DELAY)
    else:
        print("Connection failed. Invalid Slack token or bot ID?")

这一切都很好。现在，假设用户已使用命令成功创建游戏实例并开始玩游戏。在某一时刻，系统会提示用户输入王牌，如下所示：

#bot.py
...
attachments =[{
"title":"Please select index for trump suit:",
"fallback":"Your interface does not support interactive messages.",
"callback_id":"prompt_trump_suit", 
"attachment_type":"default", 
"actions":
        [{"name":"diamonds","text":":diamonds:","type":"button","value":"0"},
        {"name":"clubs","text":":clubs:","type":"button","value":"1"},
        {"name":"hearts","text":":hearts:","type":"button","value":"2"},
        {"name":"spades","text":":spades:","type":"button","value":"3"}]
}]
slack.chat.post_message(
        channel=player_id,
        as_user=True,
        attachments=attachments
        )

互动消息looks like this。单击此消息中的一个按钮的操作通过 HTTP POST 将有效负载发送到 Web 服务器。我在项目中的另一个脚本，我们将调用app.py，是一个 Flask 脚本，当用户单击其中一个按钮时，它成功接收到这个 POST 请求。接收 POST 请求的脚本部分如下所示：

#app.py
...
# handles interactive button responses for mybot
@app.route('/actions', methods=['POST'])
def inbound():
    payload = request.form.get('payload')
    data = json.loads(payload)
    token = data['token']
    if token == SLACK_VERIFICATION_TOKEN:
        print 'TOKEN is good!'
        response_url = data['response_url']
        channel_info = data['channel']
        channel_id = channel_info['id']
        user_info = data['user']
        user_id = user_info['id']
        user_name = user_info['name']
        actions = data['actions'][0]
        value = actions['value']
        print 'User sending message: ',user_name
        print "Value received: ",value
    return Response(), 200

当按钮被点击时，我得到了预期的输出：

TOKEN is good!
User sending message:  my_username
Value received:  3

所以到目前为止一切都很成功。现在，我要做的是获取该 POST 信息并使用它来调用我的bot.py 脚本中的一个函数，该函数处理王牌套装选择。问题是，如果我要调用该函数，我们称之为handle_trump_suit_selection()，我首先必须在app.py 文件中实例化一个Bot() 对象，这当然不会按预期工作，因为该函数将是使用新的Bot() 实例调用，因此不会处于与当前游戏相同的状态。

那么，我怎么才能将 POST 信息返回到 bot.py 中所需的 Bot() 实例以进行进一步处理？我是 Python 中 OOP 的新手，尤其是 Flask 和 Slack API 的新手，所以请放轻松；）。

提前致谢。

Answer 1

大获成功！

tl;博士： 基本上，解决方案是创建一个 Celery 任务，使用 Slack Events API 从 Flask 应用程序实例化机器人实例。您将任务设置为在输入所需的输入后启动，立即将所需的 Response(200) 返回给 Slack，同时并行启动机器人脚本（启动 RTM API web-socket）。

细节： 因此，如上所述，事实证明需要的是a queuing service of some sort。我最终选择了Celery，因为它相对容易与Heroku（我在其中托管 Slack 应用程序）及其易于理解的文档集成。

以这种方式开发您的 Slack 应用程序需要设置并使用 Slack Events API 从发布消息的 Slack 频道接收命令（在此示例中为“play my_game”）。Flask 应用程序 (app.py) 部分程序监听此事件，当输入与您要查找的内容匹配时，它会并行启动 Celery 任务（在 tasks.py 中，在此示例中实例化 bot.py 的 Bot() 实例） . :) 现在机器人可以使用 Slack RTM API 和 Slack Events API 来监听和响应。这允许您在 Slack 框架内构建丰富的应用程序/服务。

如果您想设置类似的东西，下面是我的项目布局和重要的代码细节。随意将它们用作模板。

项目布局：

• project_name_folder
  • app_folder
    • 静态文件夹
    • 模板文件夹
    • __init__.py
    • my_app.py
    • bot.py
    • tasks.py
  • 过程文件
  • requirements.txt

__init__.py：

from celery import Celery
app = Celery('tasks')
import os
app.conf.update(BROKER_URL=os.environ['RABBITMQ_BIGWIG_URL']) # Heroku Celery broker

my_app.py：

from flask import Flask, request, Response, render_template
import app
from app import tasks

app = Flask(__name__)

@app.route('/events', methods=['POST'])
def events():
"""
Handles the inbound event of a post to the main Slack channel
"""
  data = json.loads(request.data)
  try:
    for k, v in data['event'].iteritems():
      ts = data['event']['ts']
      channel = data['event']['channel']
      user_id = data['event']['user']
      team_id = data['team_id']

      if 'play my_game' in str(v):
        tasks.launch_bot.delay(user_id, channel, ts, team_id) # launch the bot in parallel
        return Response(), 200
  except Exception as e:
    raise

bot.py：

from slackclient import SlackClient
class Bot():
  def main():
    # opening the Slack web-socket connection
    READ_WEBSOCKET_DELAY = 1  # 1 second delay between reading from firehose
    if self.slack_client.rtm_connect():
      while True:
        command, channel, user, ts = self.parse_slack_output()
          if command and channel:
            if channel not in self.channel_ids_to_name.keys():
              # this (most likely) means that this channel is a PM with the bot
              self.handle_private_message(command, user, ts)
            else:
              self.handle_command(command, channel, user, ts)
          time.sleep(READ_WEBSOCKET_DELAY)

tasks.py：

import bot
from bot import Bot
from app import app

@app.task
def launch_bot(user_id, channel, ts, team_id):
'''
Instantiates the necessary objects to play a game

Args:
        [user_id] (str) The id of the user from which the command was sent
        [channel] (str) The channel the command was posted in
        [ts] (str) The timestamp of the command

'''
  print "launch_bot(user_id,channel)"
  app.control.purge()
  bot = Bot()
  bot.initialize(user_id, channel)
  bot.main()

Procfile（如果使用 Heroku）：

web: gunicorn --pythonpath app my_app:app
worker: celery -A app.tasks worker -B --loglevel=DEBUG

如果您有任何问题，请告诉我。我花了一点时间才弄明白，如果您对此有疑问，我很乐意为您提供帮助。