Gravações em massa

A API de gravação em massa envia várias operações de gravação para o servidor em um único comando. Use a API de gravação em massa para reduzir o número de viagens de ida e volta da rede ao realizar várias gravações por vez. Por exemplo, para realizar várias atualizações com eficiência, pode-se fazer:

collection = client['colors']
collection.bulk_write([
  {
    update_one: {
      filter: {name: 'yellow'},
      update: {'$set' => {hex: 'ffff00'}},
    },
  },
  {
    update_one: {
      filter: {name: 'purple'},
      update: {'$set' => {hex: '800080'}},
    },
  },
], ordered: true, write_concern: {w: :majority})

O exemplo a seguir mostra como executar diferentes tipos de operações na mesma solicitação:

collection.bulk_write([
  { insert_one: { x: 1 } },
  { update_one: {
    filter: { x: 1 },
    update: {'$set' => { x: 2 } },
  } },
  { replace_one: {
    filter: { x: 2 },
    replacement: { x: 3 },
  } },
], :ordered => true)

O primeiro argumento para bulk_write é a lista de operações a serem executadas. Cada operação deve ser especificada como um hash com exatamente uma chave que é o nome da operação e a especificação da operação como o valor correspondente. As operações suportadas são detalhadas abaixo. O método bulk_write também aceita as seguintes opções:

As operações válidas de escrita em massa são as seguintes:

{ insert_one: { x: 1 } }

{ update_one: {
  filter: { x: 1 },
  update: { '$set' => { x: 2 } },
  # upsert is optional and defaults to false
  upsert: true,
} }

{ update_many: {
  filter: { x: 1 },
  update: { '$set' =>  { x: 2 } },
  # upsert is optional and defaults to false
  :upsert => true,
} }

{ replace_one: {
  filter: { x: 1 },
  replacement: { x: 2 },
  # upsert is optional and defaults to false
  upsert: true,
} }

{ delete_one: {
  filter: { x: 1 },
} }

{ delete_many: {
  filter: { x: 1 },
} }