如何在 django 中等待端点请求到达？

Question

告诉我您可以用什么来等待另一个端点的响应？ 我在主页（索引）上，在表单中输入一些内容。 POST 请求被发送到另一台服务器。此时：

• 另一台服务器处理数据，并根据其正确性向我的 url /answer 发出 POST 请求（True 或 False）。
• 例如，我将被重定向到另一个页面。 如何注册另一个页面（另一个）的逻辑，以便 Django 等待从另一个服务器到 /answer 的 POST 请求，并根据此请求 True/False，我在此页面上输出所有 OK 或所有 Bad ？

url.py

urlpatterns = [
    path('index/', index, name='index'),
    path('page_2/', page_2, name='page_2'),
    path('answer/', answer, name='answer'),
]
-------------------------------------------------

views.py

def index(request):
    requests.post(example.com, data='My data')
    return redirect('page_2')

def page_2(request):
    # wait request in answer
    if request.session['answer'] is True:
        return 'Ok'
    retunr 'Bad'

def answer(request):
    data = request.data
    # send to page_2 or save in request.session['answer']
    return Response(status=200)

Answer 1

我认为这是一种奇怪的情况，如果您可以重新设计代码逻辑，以便视图函数尽快处理请求，而不是忙于等待外部事件被触发，因为它会增加响应时间，那就更好了。

但是，为了实现此目的，我们需要在 index 和 answer 视图之间建立通信通道。因此，要实现这样的通信：

• index：嘿answer！我已发送请求。我要睡觉了，等结果出来了就叫醒我。
• answer：噢，我明白了。给你。醒醒吧！
• 索引：谢谢。现在我处理它并返回我的回复。

所以这个频道可能是任何东西！数据库中的模型、redis 中的一些实体、文件系统中的一些文件等。

使用模型的一种可能的解决方案可能是：

• 创建一个模型（例如，将其命名为 ExampleRequest），由名为 < 的布尔字段组成code>received
• 在 index 视图中，在发送请求之前使用 received = False 创建一个 ExampleRequest 实例。
• 在 answer 视图中，找到之前创建的 ExampleRequest 并将其 received 字段设置为 True
• 在 index< /code> 查看，发送请求后，在 while 循环中，查询数据库，检查创建的 ExampleRequest 实例是否有 received = True?如果是，则外部服务器已调用answer。所以，休息一下，做剩下的工作；否则，只需 time.sleep(1) 并继续 while 循环。

请注意：

• 当多个客户端使用您的网站时，其中一些客户端可能会请求 index 视图，然后就会有多个 ExampleRequest 实例。在 answer 视图中，您必须能够找出当前请求与其中哪个实例相关。您可能需要在 ExampleRequest 模型中存储与该请求相关的唯一数据。
• 您可能会考虑其他服务器从未调用 answer view 的情况。因此，index 视图的 while 循环的迭代可能存在上限。
• 此外，您可以在 index 视图中捕获 ExampleRequest 实例后将其删除，以优化数据库的磁盘使用。

我再说一遍，如果您可以在前端而不是后端进行轮询，以避免高响应时间和其他同步问题，那就更好了。

Answer 2

这可能不是完整的答案，但它为您提供了方法。

def index(request):
    requests.post(example.com, data='My data')
    return redirect('page_2')

改为如下

import httpx
async def index(request):
   async with httpx.AsyncClient() as client:
      response = await client.post(example.com, data='My data')
      print(response.json())