微服务通信中如何组织延迟结果处理？

Question

我有以下系统：我的 Rails 服务器向 Flask 服务器发出命令，最新的一个立即响应状态为 200。之后 Flask 服务器运行一个具有一些耗时功能的后台任务。过了一会儿，它产生了一些结果，旨在通过 HTTP 将数据发送回 Rails 服务器（见图）

每个 Flask 数据部分都会影响多个 Rails 模型（User、Post 等...）。在这里我遇到了两个问题：

1. 在这种情况下，我应该如何在 Rails 端构建我的控制器/操作？目前，我考虑的是一个控制器，它的每个操作都对应于 Python 的“延迟”数据部分。
2. 是微服务通信的正常方式吗？或者我可以用一种不同的、更简单的方式来组织它？

Answer 1

这听起来很像您的标准 webhook 过程。 Rails 用 GET 或 POST 请求戳 Flask，过一会儿 Flask 又戳回来。

例如，假设我们有报告，在创建报告后，我们需要烧瓶来验证报告：

class ReportsController
  # POST /reports
  def create
    @report = Report.new(report_params)
    if @report.save
      FlaskClient.new.verify(report) # this could be delegated to a background job
      redirect_to @report
    else
      render :new
    end
  end

  # PATCH /reports/:id/verify
  def verify
    # process request from flask
  end
end

class FlaskClient
  include Httparty

  base_uri 'example.com/api'
  format 'json'

  def verify(report)
    self.class.post('/somepath', data: { id: report.id, callback_url: "/reports/#{report.id}/verify", ... })
  end
end

当然，Rails 应用程序实际上并不知道 Flask 何时会响应，或者 Flask 和后台服务不同。它只是发送和响应http请求。而且您绝对不希望 rails 等待，因此请保存您拥有的内容，然后钩子可以更新数据。

如果您必须在 Rails 端更新 UI 而无需用户手动刷新，您可以使用 ActionCable 形式的轮询或 websocket。