Azure / Azure/azure-functions-java-library

@CosmosDBInput ignores partitionKey

Open
#134 0 comments 0 reactions 0 assignees View on GitHub
area:java-functions
Dominant language
Java
Stars
45
Forks
49
PR merge metrics
No merged PRs in 30d

Description

In my [Micronaut Azure Function](https://micronaut-projects.github.io/micronaut-azure/latest/guide/index.html) I am using a binding `@CosmosDBInput` for event-sourcing like this:

```java
public class ChatRoomFunction extends AzureFunction {

@FunctionName("handleCommand")
public HttpResponseMessage handleCommand(
@HttpTrigger(
name = "req",
methods = HttpMethod.POST,
authLevel = AuthorizationLevel.ANONYMOUS)
final HttpRequestMessage request,
@CosmosDBInput(
name = "events",
connectionStringSetting = CONNECTION_STRING,
databaseName = DATABASE_NAME,
collectionName = "events",
partitionKey = "events--{id}") final List events,
final ExecutionContext context
) {
// function body intentionally left out
}
}

// with

public class Command {
private UUID id;

// more fields, getters, setters
}

// and

public class Event {
private String streamId; // this is the CosmosDB partition key

// more fields, getters, setters
}
```

Before, I tried doing this using `@TableInput` which seemed to worked fine.
Now I've switched to CosmosDB and for some reason it seems to ignore my `@CosmosDBInput`'s `partitionKey` value.

**Expected**: `events` should contain a list of only `Event`s having a certain `streamId` as matched by the binding parameter of the request body, i.e. `id`.

**Actual**: `events` contains a list of ALL `Event`s present in the `events` collection.

Am I missing something here? This is what the `partitionKey` is for, right?

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.