python-3.x – 用于ArangoDB的带有python-arango驱动程序的UPSERT

2023年3月9日 277次阅读

我使用
python-arango作为ArangoDB的驱动程序,似乎没有UPSERT接口.

我打算用python-arango标记这个,但我没有足够的rep来创建新标签.

我正在管理类似下面显示的功能,但我想知道是否有更好的方法来做到这一点？

def upsert_document(collection, document, get_existing=False):
    """Upserts given document to a collection. Assumes the _key field is already set in the document dictionary."""
    try:
        # Add insert_time to document
        document.update(insert_time=datetime.now().timestamp())
        id_rev_key = collection.insert(document)
        return document if get_existing else id_rev_key
    except db_exception.DocumentInsertError as e:
        if e.error_code == 1210:
            # Key already exists in collection
            id_rev_key = collection.update(document)
            return collection.get(document.get('_key')) if get_existing else id_rev_key
    logging.error('Could not save document {}/{}'.format(collection.name, document.get('_key')))

请注意,在我的情况下,我确保所有文档都有_key的值,并且在插入之前,因此我可以假设这一点成立.如果其他人想要使用此功能,请相应地进行修改.

编辑：删除了_id字段的使用,因为这不是问题的必要条件.

最佳答案 使用upsert的要点是从应用程序中保存数据库往返,这就是try / except方法不太好.

但是,当时the ArangoDB HTTP-API不提供upserts,因此python-arango无法为您提供API.

您应该使用AQL query to upsert your document来实现此目的：

UPSERT { name: "test" }
    INSERT { name: "test" }
    UPDATE { } IN users
LET opType = IS_NULL(OLD) ? "insert" : "update"
RETURN { _key: NEW._key, type: opType }

通过python-arango s db.aql.execute-interface

点赞