chore: update mongodb store method

shengchenyang · shengchenyang · commit 84914a31d3d8 · 2025-09-15T23:57:20.000+08:00
diff --git a/ayugespidertools/common/mongodbpipe.py b/ayugespidertools/common/mongodbpipe.py
@@ -79,7 +79,7 @@ def store(
             update_doc["$setOnInsert"] = ReuseOperation.get_items_except_keys(
                 data=insert_data, keys=set_data
             )
-            db[collection].find_one_and_update(
+            db[collection].update_one(
                 filter=update_rule, update=update_doc, upsert=True
             )
         else:
@@ -109,7 +109,7 @@ async def store(
             update_doc["$setOnInsert"] = ReuseOperation.get_items_except_keys(
                 data=insert_data, keys=set_data
             )
-            await db[collection].find_one_and_update(
+            await db[collection].update_one(
                 filter=update_rule, update=update_doc, upsert=True
             )
         else:

Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,7 @@ def store(`
`79`	`79`	`update_doc["$setOnInsert"] = ReuseOperation.get_items_except_keys(`
`80`	`80`	`data=insert_data, keys=set_data`
`81`	`81`	`)`
`82`		`- db[collection].find_one_and_update(`
	`82`	`+ db[collection].update_one(`
`83`	`83`	`filter=update_rule, update=update_doc, upsert=True`
`84`	`84`	`)`
`85`	`85`	`else:`
`@@ -109,7 +109,7 @@ async def store(`
`109`	`109`	`update_doc["$setOnInsert"] = ReuseOperation.get_items_except_keys(`
`110`	`110`	`data=insert_data, keys=set_data`
`111`	`111`	`)`
`112`		`- await db[collection].find_one_and_update(`
	`112`	`+ await db[collection].update_one(`
`113`	`113`	`filter=update_rule, update=update_doc, upsert=True`
`114`	`114`	`)`
`115`	`115`	`else:`