execute_item_batch can't accept multiple items for upsert and delete operations

[pamelafox]

• Package Name: azure-cosmos
• Package Version: 4.9.0
• Operating System: Mac OS X
• Python Version: Python 3.12

Describe the bug

I tried using code like this:

batch_operations = [
("upsert", tuple([session_item] + message_pair_items))
]
await container.execute_item_batch(batch_operations=batch_operations, partition_key=[entra_oid, session_id])

That results in an error in the SDK however ("operation" is undefined), arising from this code lacking "upsert"--

        elif len(args) == 2:
            if operation_type.lower() == "replace":
                operation = {"operationType": "Replace",
                             "id": args[0],
                             "resourceBody": args[1]}
            elif operation_type.lower() == "patch":
                operation = {"operationType": "Patch",
                             "id": args[0],
                             "resourceBody": {"operations": args[1]}}
                filter_predicate = kwargs.pop("filter_predicate", None)
                if filter_predicate is not None:
                    operation["resourceBody"]["condition"] = filter_predicate

Mark says that the .NET SDK has equivalent functionality for upsert and delete. And if for some reason they dont work, the error should be better.

[github-actions]

Thanks for the feedback! We are routing this to the appropriate team for follow-up. cc @AbhinavTrips @bambriz @Pilchie @pjohari-ms @simorenoh.

[kushagraThapar]

@allenkim0129 can you please take a look at this, thanks!

[simorenoh]

hi @pamelafox, sorry about the delay with replying to this - can you elaborate on what you are passing in to this single batch operation? we do have logic that checks for upsert requests in batch operations, where we expect to receive a tuple with two entries for any singular upsert operation to be used in a batch request. that is, they should be a tuple of (operation_type, request_body) - something like ("upsert", {"id": item-id, "partition_key": item_partition_key}):

I see you are passing a list to this operation - that would not work, since it would not have the resource body that is expected out of a singular upsert request, and when serializing within the SDK would have more than the single argument expected for a single item operation. We have documentation about this in our README as well:

If the idea here is to upsert several items in one batch to be sent, you'd need to supply the initial list of operations with each individual upsert request - something like:

batch_operations = []
for item in item_list:
    batch_operations.append(tuple("upsert", item)) 

and then pass that to the execute_item_batch method. Do let me know if this doesn't help or if there's any further doubts!

[github-actions]

Hi @pamelafox. Thank you for opening this issue and giving us the opportunity to assist. To help our team better understand your issue and the details of your scenario please provide a response to the question asked above or the information requested above. This will help us more accurately address your issue.

[github-actions]

Hi @pamelafox, we're sending this friendly reminder because we haven't heard back from you in 7 days. We need more information about this issue to help address it. Please be sure to give us your input. If we don't hear back from you within 14 days of this comment the issue will be automatically closed. Thank you!

[pamelafox]

This is the code that we ended up using:
https://github.com/Azure-Samples/azure-search-openai-demo/blob/main/app/backend/chat_history/cosmosdb.py#L70

It sounds like that's the correct code.