I like to stream large data files over REST directly to a Azure Blob Storage. Now i face the problem that when I send a filter with 250MB over REST to the Azure Blob Storage, but with 260MB it stuck…
I need to download very large file via REST and store it to an Azure Blobstorage. I am facing quite some Problems. For all examples, I use this call to get to the Data var flux = this.webClient .get() .uri(urlToAssert)…
I have an API where I have a Ticket entity, and the endpoint to get all the tickets is taking like 25 seconds, but in the mongo db there are only 300 tickets. The ticket entity: @Data @Document(collection = "tickets")…
Was following along with Spring + Kotlin = Modern + Reactive + Productive presentation on YouTube! by creating a Kotlin-based Spring Web Flux Reactive app using https://start.spring.io/... Generated the project using these dependencies (please note the Spring Boot and Java…
We are using MongoDB for a POC and I am stuck with below problem. We are building a page to show filter options for data. If user selects any filter, then data needs to be filtered as per selection. If…
It is necessary to filter the flow of values from the database (filtering must be performed in a reactive, non-blocking style). You need to get the incoming element, take the email field from it and validate this value. After the…
What is the difference b/w the behavior of resumeAt that accepts a timestamp to resume the notifications from vs resumeToken that accepts the resume token? return ChangeStreamOptions.builder() .filter(Aggregation.newAggregation(Example.class, matchOperationType)) .resumeAt(Instant.ofEpochSecond(1675303335)) // this is simply a unix timestamp .resumeToken(tokenDoc) // resume…
Delete Operation is not working. How can i fetch data and then delete it in a functional way? The code successfully run but it is not deleting data in database. Controller Class @DeleteMapping("/deleteUserById/{userId}") public Mono<ResponseEntity<String>> deleteUserById(@PathVariable Long userId) { return…
Here is my code: I need to save java object value as jsonb in database (r2dbc). @Getter @Setter @ToString @NoArgsConstructor @AllArgsConstructor @Table("scoring") public class ScoringModel extends BaseModel { @Column("client_id") @SerializedName(value = "clientId", alternate = {"client_id"}) private String clientId; //othres @Column("languages")…
I am getting a duplicate key error from the database (MySQL) for the scenario I have explained below. Background I need to save an entity to my database, but the entity id is not managed/generated by my system, so it…