Thanks @abserari , is this the only way to fix issue? it seems I have a lot code to refactor. I originally thought input binding can fully support the scenario of "competing consumer" mode, on the other hand, is such greedy algorithm of daprd sidecar safe enough? I means that if daprd sidecar get all current messages from queue (all message's status changed from Ready to Unack), when main container crashed for some reason, then all left messages cannot be picked up and processed by other pod?
@aronchick if using the Dapr CLI, see this: https://github.com/dapr/cli#running-sidecar-only
4 replies
Hi, could someone explain how HTTP requests in dapr are handled and what exactly happens under the hood? As an example I have a dapr service that exposes an HTTP API, implemented with the .NET core framework. So what happens exactly if I call the API from another dapr service with the
InvokeMethod method of the dapr client? Am I right that the DaprClient makes a gRPC request to the sidecar, then the sidecar searches for the service and makes a gRPC request to the sidecar of the API service. And then the sidecar makes an HTTP call to the API? If so, can someone point me to the right code in GitHub?
There are some messages talking to integrate dapr with istio. Considering there will be two sidecar in the system, what is the benefit of using istio? I am trying to understand what istio does and dapr doesn't in service mesh? I have a look at https://istio.io/latest/docs/concepts/what-is-istio/ and didn't see a big difference between dapr consepts and istio consepts. Considering i will start to build a new design and all i need service to service communication, should i place istio in a daprized environment?
1 reply
Hi, after a while we seem to lose connection to pubsub (using redis) or state store (using sql). Our application will work for a while then we start to see ERR_PUBSUB_NOT_FOUND or ERR_STATE_STORE_NOT_CONFIGURED errors in the logs. Restarting the pods will get it working again, usually. Any ideas what is causing this? We are on version 0.10.0 and also using Istio
13 replies
Hi guys, I would like to clarify the best approach for a certain use case. We have a front end react app which publishes events as messages to a Google Cloud PubSub topic. We would like to pull these messages into our dapr-enabled back-end and then process them amongst back-end Microservices using a standard Dapr redis.pubsub component. With the new ability of Dapr to connect to multiple pubsub components (in our case Google Cloud PubSub for messaging coming from outside the Dapr-system environment and Redis PubSub for messages inside Dapr) what is die best approach. Should we use Dapr Pub Sub to get messages from Google PubSub or should we use the Dapr Binding which also supports Google PubSub? Is Dapr PubSub only for communication between Dapr enabled Microservices or is it feasible to use it to get messages from an external topic source as described. What will the pros and cons be between using Dapr PubSub with Google PubSub or Dapr Bindings with Google PubSub. We are discussing architecture and this question came up without clear answers. Any insight will be very valuable - thank you!
1 reply
with different IPs and all?
@yaron2 I'm seeing the sidecar injector fail with this message:
It goes away for a while after restarting the deployment and then returns. Any idea what the problem could be? I saw the workaround here dapr/dapr#1621 (which is what was followed), but there was no link in that issue to the corresponding change in documentation. This is a version 0.8 installation.
2020/09/04 00:02:52 http: TLS handshake error from 100.96.2.0:41578: remote error: tls: bad certificateIt goes away for a while after restarting the deployment and then returns. Any idea what the problem could be? I saw the workaround here dapr/dapr#1621 (which is what was followed), but there was no link in that issue to the corresponding change in documentation. This is a version 0.8 installation.
2 replies
Hi.. I'm researching on Dapr and I have 2 questions that I haven't found answers for yet. Could anyone help?:
1) With Dapr.Workflows is it possible to manage the workflow (LogicApp) in Azure? How do we go about getting usage details and princing?
2) For Redis state store, does the current component support failover and/or Redis Sentinel? I saw that the go-redis library does.
1) With Dapr.Workflows is it possible to manage the workflow (LogicApp) in Azure? How do we go about getting usage details and princing?
2) For Redis state store, does the current component support failover and/or Redis Sentinel? I saw that the go-redis library does.
14 replies
dapr/docs#774 Request a review about doc update. The update is about to remove the nats.md and add the nats-streaming.md in how to setup pub-sub message broker.
Hi I'm having trouble getting service invocation from C# sdk to work.
Even tried running the samples at https://github.com/dapr/dotnet-sdk/tree/master/samples/Client/DaprClient.
I have "routing" up and running, and can invoke it successfully via dapr invokeGet -a routing -m 17 .
However, when running the sample Client code (with the GET invocation uncommented), i get the following error:== APP == Unhandled exception. Grpc.Core.RpcException: Status(StatusCode=Unknown, Detail="context deadline exceeded")
I get the same error when I try to invoke my own service code from another of my own services, which is what started me down this road. After getting the excact same error from sample code i figured it's time to ask for help :P Any ideas? Running on OSX if that matters.
8 replies
Asked a question about using Dapr and CAP together here: dotnetcore/CAP#662 . CAP automates outbox pattern for transactional messaging but talks directly to underlying bus, hence seems incompatible with Dapr pubsub. Comments are welcome.
5 replies
I just moved from 0.9.0 -> 0.10.0 with the C# sdk and it broke my pub/sub. Previously it took one string parameter and now it takes two (pubsubName and topicName). I don't know which one was there first and am struggling to find the documentation to describing how they are used. Can someone point me to the documentation on the change?
20 replies
Hi, I have a question about pubsub component's metadata name, Is it a disadvantage that the same Pubsub component uses the same metadata name for many microservices? Is it affect performance etc. For example, I have 3 microservices they have 3 different methods and they are listening to 3 different topics(the same pubsub metadata name) and i used the same pubsub component(nats.streaming) YAML each of them. What is the best practices for this mechanism
5 replies
@piotrmsc Hi Piotr, Did you produce any documentation on how to get Istio working with Dapr, we are bumping into issues ourselves but getting into trouble with Redis and Dapr and the EnvoyProxy (Istio manages) seems to require more configuration. Any help or pointers would be appreciated, thanks , Anthony.
Hi All!
We are trying to POC dapr for our company, really like what its trying to achieve.
We have it running in Kubernetes and want to setup dapr running on a VM.
My question is
How do i step these two locations to communicate with each other?
How does service discovery work across hosts?
7 replies
Hi, is it possible to create and register custom middleware components in C#? If so, is there an example I could look at? (ref https://github.com/dapr/docs/tree/master/concepts/middleware )
2 replies
Hi guys , I have a question about the pub/sub mechanism. When I use nats as a service broker, I am publishing a event on topic. if subscribers are not alive, exception is throwing what should I do for preventing this problem? According to document ;
- "Streaming server will store all messages published to the streaming API into a channel (no subscribers need yet to exist)"
- "When a subscriber subscribes to a subject, messages in the channel are played back."
5 replies
Hi, I have sample .net core web api using Dapr and i make simple post request to another api ( 'http://localhost:3500/v1.0/publish/neworder') . I wanna attach running Dapr Application and Debug Dapr with VSCode. Is it possible? How can i? Thanks.
are there plans to add key expiration to the state store?
Not solving this (silly) issue by myself.
Dotnet SDK 0.10, two ASP.NET http WebApi projects: app order-service has to invoke app reservation-service method via await daprClient.InvokeMethodAsync<object>("reservation-service", "reserve", data, httpExtension);.
Both applications correctly appear in VS Code extension while debugging, their methods can be invoked via http or VS Code extension, the reservation-service can also be invoked with DaprClient client.InvokeMethodAsync by a console proj I launch as a Dapr app.
Once order-service, in the scope of a method call, does attempt to invoke reservation-service method, I received the error: "Error starting gRPC call: No connection could be made because the target machine actively refused it."
Any hint on the plausible cause?
The full stack trace:
Grpc.Core.RpcException: Status(StatusCode=Internal, Detail="Error starting gRPC call: No connection could be made because the target machine actively refused it.")
at Dapr.Client.DaprClientGrpc.MakeGrpcCallHandleError[TResponse](Func`2 callFunc, CancellationToken cancellationToken)
at Dapr.Client.DaprClientGrpc.MakeInvokeRequestAsync(String appId, String methodName, Any data, HTTPExtension httpExtension, CancellationToken cancellationToken)
at Dapr.Client.DaprClientGrpc.InvokeMethodAsync[TRequest](String appId, String methodName, TRequest data, HTTPExtension httpExtension, CancellationToken cancellationToken)
at sample.microservice.order.Controllers.OrderController.SubmitOrder(Order order, DaprClient daprClient) in C:\Repos\dapr-samples\chapter03\sample.microservice.order\Controllers\OrderController.cs:line 33
at lambda_method(Closure , Object )
at Microsoft.Extensions.Internal.ObjectMethodExecutorAwaitable.Awaiter.GetResult()
at Microsoft.AspNetCore.Mvc.Infrastructure.ActionMethodExecutor.AwaitableObjectResultExecutor.Execute(IActionResultTypeMapper mapper, ObjectMethodExecutor executor, Object controller, Object[] arguments)
at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.<InvokeActionMethodAsync>g__Awaited|12_0(ControllerActionInvoker invoker, ValueTask`1 actionResultValueTask)
at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.<InvokeNextActionFilterAsync>g__Awaited|10_0(ControllerActionInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted)
at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.Rethrow(ActionExecutedContextSealed context)
at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.Next(State& next, Scope& scope, Object& state, Boolean& isCompleted)
at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.<InvokeInnerFilterAsync>g__Awaited|13_0(ControllerActionInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted)
at Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.<InvokeFilterPipelineAsync>g__Awaited|19_0(ResourceInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted)
at Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.<InvokeAsync>g__Awaited|17_0(ResourceInvoker invoker, Task task, IDisposable scope)
at Microsoft.AspNetCore.Routing.EndpointMiddleware.<Invoke>g__AwaitRequestTask|6_0(Endpoint endpoint, Task requestTask, ILogger logger)
at Microsoft.AspNetCore.Authorization.AuthorizationMiddleware.Invoke(HttpContext context)
at Microsoft.AspNetCore.Diagnostics.DeveloperExceptionPageMiddleware.Invoke(HttpContext context)
first i installed dapr:
and docker:
now i'm facing dapr init issue:
i' don't know it looks at the version v0.2.0 . the first script install has installed the version V0.10.0
@hichamveo it tries to download version 0.2.0 of the dashboard, not Dapr. However we dont yet have an ARM image for the dashboard. Theres an issue tracking it here: dapr/dashboard#75
i wasn't aware that there is no ARM image
so I cannot init dapr and work with without this dashboard?