0

我有一些代码可以检查来自 Stripe 的 Webhook 的数据。现在我得到了一些代码来查询我的数据库以检查付款是否已确认。我正在尝试编写一个函数来检查我的数据库以查看是否已确认付款，如果尚未确认付款，则程序应等待 5 秒然后再次检查，最多检查 5 次。如果在第五次尝试后付款仍未显示为已确认，那么我需要重定向用户。

这是因为我的代码执行速度可能比 Stripe 将其 webhook 响应返回到我的服务器更快。

当前代码如下。如何在 if 语句上创建“循环”？

def accepted(request, payment_id):

    r = Usertasks.objects.all().filter(user=request.user).filter(randomURL=payment_id).values("TaskPostedToNetwork")
    e = Usertasks.objects.all().filter(user=request.user).filter(randomURL=payment_id).values("PaymentConfirmed")
    if r == "False" and e == "yes":
        print("true")
    else:
        return redirect('dashboard:index')
    return render(request, 'request.html',)
4

2 回答 2

1

您可以通过将查询/检查逻辑包装在一个for循环中来做到这一点。由于您最多希望执行这些操作 5 次，因此您可以进行for循环，range(5)并且由于您使用成功return，循环将在成功时停止。因此最多5次。

在另一种情况下，当您再次检查而不是退出函数时，您可以调用time.sleep(5)停止执行并等待 5 秒。

如果循环完成（执行块 5 次但未成功并退出），那么您将到达该return redirect...行。

像这样：

import time

def accepted(request, payment_id):
    seconds_between_calls = 5
    max_calls = 5
    for _ in range(max_calls):
        r = Usertasks.objects.all().filter(user=request.user).filter(randomURL=payment_id).values("TaskPostedToNetwork")
        e = Usertasks.objects.all().filter(user=request.user).filter(randomURL=payment_id).values("PaymentConfirmed")
        if r == "False" and e == "yes":
            print("true")
            return render(request, 'request.html',)
        else:
            # try again
            time.sleep(seconds_between_calls)    
    return redirect('dashboard:index') # if max_calls hit
于 2019-03-21T21:36:14.033 回答
0

您可以为重试次数和每次尝试的睡眠时间定义一个变量。（目前你有 5 和 5 但它可能会改变，你不想以后手动编辑每个出现。）

在重试次数和time.sleep(time_per_try). 注意：你必须这样import time做。

于 2019-03-21T21:35:18.183 回答