Как одним запросом перезаписать документы в MongoDB?

Question

[cascado]

Добрый день. Суть вопроса в следующем:
есть n документов в коллекции в базе, есть m документов для записи в коллекцию, каждый документ имеет уникальный идентификатор "user", общий вид {"user": "22", "info": {...}}. Как мне одним присестом m документов запихнуть в коллекцию, причем так, чтоб если юзер совпал, он перезаписывал документ, а если нет - добавлял его в коллекцию? Ползал по документации, не нашел. Заранее спасибо.

Answer 1

[Алексей Ярков]

update upsert

Comments

[cascado]

Алексей, можно с этого места поподробнее? Я смотрел документацию по update, возможен апдейт множества документов критерию (критериям), но результирующее значение будет одинаковым. Я видимо что-то недопонимаю, не могли бы вы прояснить этот момент?

[Алексей Ярков]

cascado: upsert:true создаст новые документы, если не найдет совпадений по условию

[Алексей Ярков]

Вы код дайте, который у вас. А мы поможем ))

[cascado]

А как-то так я предпологал update, но хрень получается с ним, пробовал и upsert=True.
async def update_sorted_friends(user, cache, collect):
assert isinstance(cache, list), "uids isn't list" # list of dicts
result = await collect.update({"user":{"$in": [i["user"] for i in cache]}}, cache)
print('set_sorted_friends: %s' % repr(result))
return result

[Алексей Ярков]

Блин, отформатируйте код.
И ссылку на фреймворк для работы с Монгой

[cascado]

motor.readthedocs.io/en/stable/tutorial-asyncio.html - motor и asyncio

[cascado]

https://gist.github.com/anonymous/13d5028208acb1fb...

[Алексей Ярков]

multi=True, upsert=True
Пробовали так?

[Алексей Ярков]

На gist комментарий написал

[cascado]

Алексей Ярков: там есть проблема - я не могу во второй параметр добавить список словарей (читай: будущих документов в базе), поскольку метод хочет словарь, в этом и проблема: он ждет статичного значения поля (полей), multi же позволяет лишь в множестве документов выставить одни и те же значения. А мне нужно вроде как сопоставить то что есть у меня, и то что есть в базе по ключу "user" в документ.

[Алексей Ярков]

cascado: Ну раз не хочет список, то тогда циклом по этому списку замену делать. Я хз как еще.

[cascado]

Алексей Ярков: проблема в том, что у меня под 100к таких документов под запись в базу, и еще 50к уже в базе, так что не особо удачная затея делать это в цикле по одному, поэтому я здесь.

[Алексей Ярков]

cascado: Ну 100к не так уж и много, если не часто )) А нельзя структуру документа изменить? Чтоб хранить массив:

{"user": "1", "cache": [{"10": 10}, {"11": 11}, {"12": 12}]}

[cascado]

Уже изменил. collect.update({}, {"$set": doc}, upsert=True). Все данные в пределах 1 документа, вопрос в том, когда кончатся 16 мб, выделенные на документ.

[Алексей Ярков]

cascado: Если найдете выход - дайте ссылку. Тоже интересно ))

[cascado]

Алексей Ярков: решения в 1 команду нет, есть решение в 1 запрос, https://docs.mongodb.com/v3.0/core/bulk-write-oper...