TypeError update() 使用 $setOnInsert 获取参数“upsert”的多个值

Question

我正在尝试扫描文件系统中的文件 - 如果文件位于数据库中，则更新。如果没有则插入一条新记录。但我收到此错误“TypeError update() 获得了参数‘upsert’的多个值”

我在这里做错了什么？

def scan_for_file(dir_path, storage_bucket):
    for file in os.listdir(dir_path):
        curpath = os.path.join(dir_path, file)
        if os.path.isfile(curpath):
            print('found file:', file)
            print('checking db')
            collection = db.file_collection
            cursor = collection.find({'file_path': curpath})
            for document in cursor:
                file_db_id = document['_id']
                file_accessed = datetime.datetime.fromtimestamp(os.path.getatime(curpath))
                file_modified = datetime.datetime.fromtimestamp(os.path.getmtime(curpath))
                file_created = datetime.datetime.fromtimestamp(os.path.getctime(curpath))
                file_size = os.stat(curpath).st_size
                file_convert_size = convert_size(file_size)
                utc_datetime = datetime.datetime.utcnow()
                update_id = collection.update_one({'_id': file_db_id}, {
                    "$set": {
                    "file_size": file_convert_size,
                    "file_size_bytes": file_size,
                    "process_datestamp": utc_datetime.strftime("%Y-%m-%d %H:%M:%S"),
                    "file_created": file_created,
                    "file_accessed": file_accessed,
                    "file_modified": file_modified}},
                    {
                    "$setOnInsert": {
                    "file_path": curpath,
                    "file_name": file,
                    "file_size": file_convert_size,
                    "file_size_bytes": file_size,
                    "process_datestamp": utc_datetime.strftime("%Y-%m-%d %H:%M:%S"),
                    "file_$reated": file_created,
                    "file_accessed": file_accessed,
                    "file_modified": file_modified}}, upsert=True,
                                                  )
                update_id
                print('ID Updated:', file_db_id)
                print('updating document id:')
        else:
            print('This is not a file:', file)

Answer 1

太长了；该代码有两个错误：upsert=True,。一个额外的“,”和一个额外的“{}”

将您的更新操作修改为：

update_id = collection.update_one(
    {'_id': file_db_id},
    {
        "$set": {
                "file_size": file_convert_size,
                "file_size_bytes": file_size,
                "process_datestamp": utc_datetime.strftime("%Y-%m-%d %H:%M:%S"),
                "file_created": file_created,
                "file_accessed": file_accessed,
                "file_modified": file_modified
        },
        "$setOnInsert": {
                "file_path": curpath,
                "file_name": file,
                "file_size": file_convert_size,
                "file_size_bytes": file_size,
                "process_datestamp": utc_datetime.strftime("%Y-%m-%d %H:%M:%S"),
                "file_$reated": file_created,
                "file_accessed": file_accessed,
                "file_modified": file_modified
        }
    },
    upsert=True)

{}您的代码有两个错误：首先，您为$set和$setOnInsert请分别添加一个额外的错误

另外，你正在做upsert=True,. 请参阅此额外,内容，这会在 Python 中生成一个元组。