jquery - 当 Tornado 应用程序的多个实例在数据库中插入项目时，如何避免在 MongoDB 中重复插入？

Question

我在 Tornado 中构建了一个简单的愿望 list 应用程序。用户将 URL 添加到产品中，应用程序会持续跟踪其价格。流程很简单，用户登录，有一个表单，用户在表单中粘贴/输入 url，然后单击提交。这会向我的服务器发出一个发布请求，并且该 url 将被添加到数据库中。

对于提交，我使用的是ajax。因此，它提交请求并刷新页面中的愿望 list 表。然而，由于这需要时间，用户认为该应用程序无法运行，并倾向于多次按“提交”。这需要时间，因为我的服务器会验证 URL、获取其价格、图像和其他详细信息。

在初始阶段，我直接与 Tornado 服务器对话。当我多次按下提交按钮时， Tornado 只会添加一次。我不知道它如何设法忽略相同的请求，也不知道它如何找出正在处理的相同请求。因为它从未发生过，所以我从来没有想过它。

现在有四个 Tornado 实例在 Nginx 服务器后面运行。所以我猜当多次按下提交时，Nginx 正在将请求传递给不同的 Tornado 实例。

那么我该如何避免这种情况呢？

• 我可以在浏览器中为每个 session 创建本地存储并维护 URL 列表。当按下提交时，如果 URL 已存在于列表中，则不发送请求。每当选项卡关闭时我都会销毁此存储。

• 提交网址后禁用提交按钮，直到收到服务器的回复

• 在按下提交时给出 Facebook 风格的通知，并希望用户不要再次按下提交。

• 将 nginx 负载均衡器配置为在 ip-hash 模式下工作。以便用户始终获得相同的 Tornado 实例的服务

• 可能以某种方式配置 nginx，使其忽略与 Tornado 单个实例之前所做的相同的 POST 请求？

这是有问题的代码(不确定它是否真的重要):

class ProductsHandler(BaseHandler):
    @tornado.web.authenticated
    def get(self):
        # ...
        # ...

    def post(self):
        user_email = self.get_secure_cookie('trakr')
        user_db = self.application.db.users
        product_db = self.application.db.products
        product_url = self.get_argument('product-url', None)
        if not product_url:
            self.redirect('/products')
            return

        vendor, url = utils.get_vendor(product_url)

        if not vendor:
            self.redirect('/products')
            return

        # this is where it checks whether the URL is already present in DB or not
        product_doc = product_db.find_one({'url': url})

        if not product_doc:
            # ...
            # ...            
            product_url, product_name, product_img_url, product_price = vendor_func_map[vendor_id](url)

            product_id = str(product_db.insert({'vendor_name': vendor_name,
                'vendor_id': vendor_id, 
                'name': product_name, 'url': url,
                'img_url': upload_to_imgur(product_img_url), 
                'price': product_price
                # ...
                # ...
                }))
        else:
            product_id = product_doc['_id']

        # add this product to users db
        # ...
        self.redirect('/products')

和ajax的jquery代码:

<script type="text/javascript">
    $(document).ready(function(){
        $("#product-add-form").on('submit',function(){
            var product_url = $("#product-url").val();
            console.log(product_url)
            var dataString = 'product-url='+ product_url
            $.ajax({
                type: "POST",
                url: "products",
                data: dataString,
                success: function() {
                    $('#product-table-div').load("/products #product-table-div")
                }
            });
        return false;
        });
    });
</script>

HTML 表单:

<div id="product-add">
    <form action="/products" method="post" id="product-add-form">
        <fieldset>
            <label for="product-url">Product-Url</label>
            <input class="text-input" id="product-url" name="product-url" tabindex="1" type="text" value="">
        </fieldset>
        <div id="form_btn">
            <input id="prodadd-btn" class="btn btn-blue" type="submit" value="Submit" tabindex="3">
        </div>
    </form>
</div>

Answer 1

正如我在 Tornado 邮件列表中所说的那样:我看到您正在将 PyMongo 与 Tornado 一起使用。我不推荐这种方法，因为长时间运行的 MongoDB 操作会阻止整个 Tornado 进程的所有工作。 (我维护 Motor，Tornado 的非阻塞 MongoDB 驱动程序。)但是 PyMongo 确实具有避免竞争条件的优势。

在代码中查询产品，如果不存在则将其插入。这对于单个 Tornado 进程效果很好，因为它一次处理一个请求，并且在查询和插入之间不会被中断。如果它没有找到文档，那么稍后当它尝试插入时仍然没有文档。

但是，对于多个 Tornado 进程，用户可以快速按下按钮两次，并且会发生类似的情况:

1. 处理 A 查询，未找到任何产品。
2. 进程 B 查询，未找到产品。
3. 进程 A 插入文档。
4. 进程 B 插入重复文档。

我愿意:

• 在开始 AJAX POST 之前禁用“提交”按钮。确保显示微调器，并在超时、HTTP 500 或其他错误后重新启用该按钮。
• 在产品集合中应唯一的字段上创建唯一的复合索引。
• 决定如果发生 pymongo.errors.DuplicateKeyError ，您的 Python 代码将如何处理。 (向用户提出信息性错误可能没问题。)