Azure / Azure/azure-functions-java-library

@CosmosDBInput ignores partitionKey

Abierto
#134 0 comentarios 0 reacciones 0 asignados Ver en GitHub
area:java-functions
Lenguaje dominante
Java
Estrellas
45
Forks
49
Métricas de merge de PR
Sin PR fusionados en 30 d

Descripción

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?

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Línea de trabajo

Comienza con la anotación @CosmosDBInput en handleCommand y sigue cómo se resuelve su valor partitionKey a partir del cuerpo de la solicitud. Reproduce el ejemplo con la colección events y, después, verifica si el binding filtra por el streamId solicitado; se considera terminado cuando el binding devuelve solo los eventos coincidentes o documenta claramente el comportamiento compatible.

Escrito por el modelo de indexación a partir del texto del issue.

Evaluación

Stack tecnológico
azure, java
Área
backend, cloud
Tipo de issue
Error
Dificultad
4/5
Tiempo estimado
3-5 días
Estado de actividad
Estancado
Claridad
Bastante claro
Aptitud para principiantes
35/100

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.