resp = client.bulk(
body=[
{
"update": {
"_id": "1",
"_index": "index1",
"retry_on_conflict": 3,
}
},
{"doc": {"field": "value"}},
{
"update": {
"_id": "0",
"_index": "index1",
"retry_on_conflict": 3,
}
},
{
"script": {
"source": "ctx._source.counter += params.param1",
"lang": "painless",
"params": {"param1": 1},
},
"upsert": {"counter": 1},
},
{
"update": {
"_id": "2",
"_index": "index1",
"retry_on_conflict": 3,
}
},
{"doc": {"field": "value"}, "doc_as_upsert": True},
{"update": {"_id": "3", "_index": "index1", "_source": True}},
{"doc": {"field": "value"}},
{"update": {"_id": "4", "_index": "index1"}},
{"doc": {"field": "value"}, "_source": True},
],
)
print(resp)