Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
    clintsinger
    @clintsinger
    As it is, at the moment I am exiting VS to cause the containers to tear down then restarting it to get the daprd containers back to square one.
    Krishnanunni k
    @krishnanunnik
    A noobie question on the state store part. I have a redis store in place. Is there any way to perform queries like keys matching prefixes or native redis operations other than save and get ?
    https://github.com/dapr/docs/blob/master/reference/api/state_api.md#get-bulk-state this describes about getting bulk data, how can we achieve different query possibilities - via Code
    I usePython SDK
    EmixamZ
    @EmixamZ
    Morning guys, hope you are well,
    It there any roadmap for dapr release ?
    I can't wait to use it in production :)
    3 replies
    mbehrisch
    @mbehrisch
    Hi. Now I can really ask the question: Is there a chance to expose a gRCP stream through dapr? I learned from @yaron2 that grcp service-to-service calls are handled internally as unary rpcs (which is in line with all the documentation that I have seen and the ìnvoke API). But I guess I'm not the only person who wants to expose streams. Is there a workaround?
    Yaron Schneider
    @yaron2
    Hey everyone, you're welcome to join our community call starting in 5 minutes: https://us02web.zoom.us/j/85305980190 (password: eWRhSklVTjJjSnhTaURDcFZaU2ZzQT09)
    Nkosinathi Sangweni
    @malotho
    This password never works for me.
    3 replies
    clintsinger
    @clintsinger
    If I am setting up a developer workflow and I need to get different configuration for each developer, for example, the state store component is based on cosmosdb but each developer has their own account. Would the best way to do that is to use secrets and each developer has their own version? We are using docker-compose for development so is there a way to store that information either on the developers local machine or in their environment variables?
    1 reply
    clintsinger
    @clintsinger
    When using actors is it appropriate to store some state in in local actor memory or should it always go through the state manager? If I am using cosmosdb as the state store that creates potentially unnecessary cost. Could I just write changes and treat the actor instance as a cache only refreshing it when it is created?
    3 replies
    georgestevens99
    @georgestevens99
    Thank you so much for implementing High Availability for Dapr side cars in K8s clusters as you demonstrated in yesterday's community meeting. Please also implement optional HA for other scenarios as well, outside clusters. For example for edge scenarios, for on-prem legacy VM scenarios, for cloud VM scenarios, for edge or on-prem to cloud hybrid scenarios. For my needs such HA would be most useful for Pub/Sub usage. Widespread HA capabilities like that will make Dapr a very strong link in the web of communications found in modern distributed systems! Again, thanks!
    Phaero_X
    @HemSoft
    Hi! Trying to get the twitter-sentiment-processor (demo1/provider-net) up and running locally using Windows 10, VSCode and dapr 0.9. After entering the twitter credentials and trying to do a dapr run I'm not getting any tweets in. I've verified the twitter credentials and tried changing the query string to very common keywords but nothing is incoming. Any ideas on how to troubleshoot this. I'm completely new to dapr and doing a SPIKE to see how dapr can help us writer better microservices. TIA!
    35 replies
    The service seems otherwise to be up and running. I'm seeing all the dapr initialization logs in the VSCode terminal.
    Dhi Aurrahman
    @dio
    Do you think Zipkin will get benefit if it implements gRPC streaming for data collections?
    1 reply
    Kai Walter
    @KaiWalter
    @yaron2 Is there (with Kubernetes) a way to make the dapr sidecar services come up as LoadBalancer instead of only ClusterIP? So that I can address these e.g. from API Management.
    I checked https://github.com/dapr/dapr/blob/master/pkg/operator/handlers/dapr_handler.go line 152+ but see only a fix ClusterIP implementation.
    11 replies
    Yaron Schneider
    @yaron2
    George Luiz Bittencourt
    @glzbcrt
    Hello, is there any place where I can find the roadmap? My company is at the very begining of a project and we would like to use Dapr, but right now it is not recommend for productions workloads.
    sedat-eyuboglu
    @sedat-eyuboglu
    @glzbcrt i have asked before, it is planned to be stable at end of this year. Also a rc version is released. We also planing to include dapr in our new platform and currently developing our poc parts by including dapr.
    George Luiz Bittencourt
    @glzbcrt
    thanks @sedat-eyuboglu !
    Roberto Diaz
    @rdiaz82
    Hi!! I just finished writing down an idea to support complex queries on databases using bindings dapr/components-contrib#441 I would like to get your feedback about it. I would very happy to contribute to the project implementing it :)
    9 replies
    Kai Walter
    @KaiWalter
    Hey fellow Daprados - please let me know whether this makes sense to any of you: https://dev.to/kaiwalter/simple-approach-to-run-and-debug-multiple-net-dapr-projects-w-o-docker-289k
    6 replies
    Jelle Bens
    @jellebens
    @yaron2 i got dapr working together with ISTIO, seems no longer to be a need to override the istio tls settings
    1 reply
    AbserAri
    @abserari
    https://www.yuque.com/abser/architecture/artboards/151574 I draw some pictures for dapr sourcecode. Hope my share to be helpful.
    2 replies
    Phaero_X
    @HemSoft
    Hi again. Are there any samples that demonstrate the retry logic? For some reason PublishEventAsync() stopped retrying when I return 500 from my Subscriber just to demonstrate the retry logic. AFAIK the retry logic is currently only linear and not configurable - is that right? Trying to troubleshoot this issue. Thanks.
    1 reply
    Gunnar L. Rasmussen
    @gunnarlr
    The https://github.com/dapr/quickstarts/tree/master/pub-sub example shows subscriptions set up with three keys: "pubsubName", "topic" and "route". The two first makes sense for me. What does "route" mean?
    1 reply
    sedat-eyuboglu
    @sedat-eyuboglu

    while debuging with VS Code extension i am getting

    time="2020-08-25T14:22:23.6736781+03:00" level=warning msg="error establishing client to placement service: rpc error: code = Unavailable desc = connection error: desc = \"transport: Error while dialing dial tcp [::1]:50005: connectex: No connection could be made because the target machine actively refused it.\"" app_id=clientcred instance=xxxxxx scope=dapr.runtime.actor type=log ver=0.10.0

    Docker hosts the placement at 6050 So i applied "placementAddress": "localhost:6050" in the tasks.json. After that the message disapered.

    2 replies
    Hanz van Aardt
    @hanzvanaardt
    Hi there, I am having a hard time troubleshooting the Daprd sidecars and would love some guidance. For example I have a working statestore yet when I try to access it I receive "{"message":"Could not get state."}". The daprd sidecar does not show any log and my main application container simple shows the logs - {"message":"Could not get state."}. I am at a loss on how I should start troubleshooting. Is Dapr working, is the statestore working or the issue with communication between the main application container and the daprd. Any assistance will be very welcome. Thank you.
    10 replies
    Mariusz Zieliński
    @mariozski
    Welcome everyone! I'm trying to get DAPR working on MacOS with docker-machine running in VMware Fusion. I'm not entirely sure how to configure things up... when I want to get through getting started and do "dapr run --app-id nodeapp --app-port 3000 --dapr-http-port 3500 node app.js" I get this error message: == DAPR == 2020/08/25 23:34:57 failed to send the request: Post "http://localhost:9411/api/v2/spans": dial tcp [::1]:9411: connect: connection refused
    8 replies
    I am not sure if that error is because dapr cli is trying to reach 9411 port of local machine? (docker is running in a VM with different IP address)
    AbserAri
    @abserari
    I saw someone in the community write an article about Dapr, and I wanted to write one. Introduction to Dapr Source Code With a Pub-Sub Sample Hope it will be helpful.
    Edward.Chan
    @EdwardChange4
    How do I debug a DAPR program with VS2019?
    1 reply
    sedat-eyuboglu
    @sedat-eyuboglu
    @yaron2 According to @georgestevens99 writes, I am trying to understand why the sidecar in k8s cluster is NOT HA. When i depoly multiple replicas of my pod, the sidecar is also multiplied. Am i wrong? Can you make it more clear. Also can you give the link of that call's record. Thank you
    Yaron Schneider
    @yaron2
    @sedat-eyuboglu the sidecars being highly available are a result of your deployment being highly available, so like you say, it is HA when running multiple replicas.
    Hanz van Aardt
    @hanzvanaardt

    Hi there, sending a message to a pubsub topic results in the following error in the Dapr sidecar. time="2020-08-26T16:51:45.271826823Z" level=error msg="error from operator stream: rpc error: code = Unavailable desc = transport is closing" app_id=exampleappname instance=exampleinstancename-5bfcd46f9-f6254 scope=dapr.runtime type=log ver=0.10.0

    How will I know that the pubsub component is functioning properly?

    1 reply
    Yanzhi Li
    @Li-Yanzhi
    If I use dapr and a pod to process the queue messages via input bindings, the messages will be processed sequentially (one by one) or concurrently? To my understanding, the pod need expose a webapi endpoint to dapr sidecar, will this result that dapr post a new message to pod when a previous message has not finish processing (this means the pod will process multiple messages at same time) ?
    2 replies
    FluentGuru
    @FluentGuru
    Hey guys! how do you do service discovery for deployments in docker compose?
    7 replies
    sedat-eyuboglu
    @sedat-eyuboglu
    Is there any known issue with dapr in OpenShift?
    1 reply
    ozturkcagtay
    @ozturkcagtay
    Hi, developing service calls with dapr. I have a problem, I make my service call using dapr client, there is no problem. But whenever I connect to the corporate network with vpn, the service calls are "RpcException: Status (StatusCode = Unknown, Detail =" context deadline exceeded ")
    Although both services are running in my machine location, what causes this situation?
    1 reply
    Tugay Ersoy
    @Admiralkheir
    Hi, I have a problem with pub/sub messaging, Running 2 service on my local machine with local dapr, all have a different port (grpc, metrics, etc) one service published event then subscriber triggering and returning 500 (for testing pub/sub mechanism) after that I didn't notice any triggering for my subscriber but according to document, it must triggering again https://github.com/dapr/docs/tree/master/howto/consume-topic, help pls ty.
    11 replies
    Yanzhi Li
    @Li-Yanzhi
    Hi there, does anyone have experience about how to use dapr with kubernetes job? If I run a normal pod, I can expose a webapi to dapr sidecar to receive messages from input binding, but kubernetes job always is a console application and will not expose webapi to receive message, then how can the job application (e.g. console) receive message from dapr sidecar?
    2 replies
    AbserAri
    @abserari
    Hello guys, I wonder how Dapr realized the at-least-once semantics? Is Dapr depend on the underlying message bus? Nats don't promise the ack but nats-streaming do. Does it mean that when use nats as pubsub component dapr couldn't promise the at-least-once semantics?
    2 replies
    Ravindra
    @Ravindra-a
    Hi, Today when I installed dapr in my AKS cluster I see following error in dapr-operator pod
    kubectl logs -n dapr-system dapr-operator-d7fb8dc96-srrn5
    time="2020-08-30T19:07:44.595756486Z" level=info msg="log level set to: info" instance=dapr-operator-d7fb8dc96-srrn5 scope=dapr.operator type=log ver=0.10.0
    time="2020-08-30T19:07:44.596221515Z" level=info msg="metrics server started on :9090/" instance=dapr-operator-d7fb8dc96-srrn5 scope=dapr.metrics type=log ver=0.10.0
    time="2020-08-30T19:07:44.59679205Z" level=info msg="starting Dapr Operator -- version 0.10.0 -- commit 6032dc2" instance=dapr-operator-d7fb8dc96-srrn5 scope=dapr.operator type=log ver=0.10.0
    time="2020-08-30T19:07:45.005094919Z" level=info msg="Dapr Operator is started" instance=dapr-operator-d7fb8dc96-srrn5 scope=dapr.operator type=log ver=0.10.0
    I0830 19:07:45.005169 1 leaderelection.go:242] attempting to acquire leader lease dapr-system/operator.dapr.io...
    E0830 19:07:45.007903 1 reflector.go:153] pkg/mod/k8s.io/client-go@v0.17.2/tools/cache/reflector.go:105: Failed to list v1alpha1.Component: v1alpha1.ComponentList.Items: []v1alpha1.Component: v1alpha1.Component.Spec: v1alpha1.ComponentSpec.Metadata: []v1alpha1.MetadataItem: v1alpha1.MetadataItem.Value: ReadString: expects " or n, but found 6, error found in #10 byte of ...|,"value":60},{"name"|..., bigger context ...|gqc7ypnZUV4Ixw="},{"name":"timeoutInSec","value":60},{"name":"disableEntityManagement","value":false|...
    E0830 19:07:46.010398 1 reflector.go:153] pkg/mod/k8s.io/client-go@v0.17.2/tools/cache/reflector.go:105: Failed to list
    v1alpha1.Component: v1alpha1.ComponentList.Items: []v1alpha1.Component: v1alpha1.Component.Spec: v1alpha1.ComponentSpec.Metadata: []v1alpha1.MetadataItem: v1alpha1.MetadataItem.Value: ReadString: expects " or n, but found 6, error found in #10 byte of ...|,"value":60},{"name"|..., bigger context ...|gqc7ypnZUV4Ixw="},{"name":"timeoutInSec","value":60},{"name":"disableEntityManagement","value":false|...
    E0830 19:07:47.012701 1 reflector.go:153] pkg/mod/k8s.io/client-go@v0.17.2/tools/cache/reflector.go:105: Failed to list v1alpha1.Component: v1alpha1.ComponentList.Items: []v1alpha1.Component: v1alpha1.Component.Spec: v1alpha1.ComponentSpec.Metadata: []v1alpha1.MetadataItem: v1alpha1.MetadataItem.Value: ReadString: expects " or n, but found 6, error found in #10 byte of ...|,"value":60},{"name"|..., bigger context ...|gqc7ypnZUV4Ixw="},{"name":"timeoutInSec","value":60},{"name":"disableEntityManagement","value":false|...
    E0830 19:07:48.015172 1 reflector.go:153] pkg/mod/k8s.io/client-go@v0.17.2/tools/cache/reflector.go:105: Failed to list
    v1alpha1.Component: v1alpha1.ComponentList.Items: []v1alpha1.Component: v1alpha1.Component.Spec: v1alpha1.ComponentSpec.Metadata: []v1alpha1.MetadataItem: v1alpha1.MetadataItem.Value: ReadString: expects " or n, but found 6, error found in #10 byte of ...|,"value":60},{"name"|..., bigger context ...|gqc7ypnZUV4Ixw="},{"name":"timeoutInSec","value":60},{"name":"disableEntityManagement","value":false|...
    E0830 19:07:49.017291 1 reflector.go:153] pkg/mod/k8s.io/client-go@v0.17.2/tools/cache/reflector.go:105: Failed to list v1alpha1.Component: v1alpha1.ComponentList.Items: []v1alpha1.Component: v1alpha1.Component.Spec: v1alpha1.ComponentSpec.Metadata: []v1alpha1.MetadataItem: v1alpha1.MetadataItem.Value: ReadString: expects " or n, but found 6, error found in #10 byte of ...|,"value":60},{"name"|..., bigger context ...|gqc7ypnZUV4Ixw="},{"name":"timeoutInSec","value":60},{"name":"disableEntityManagement","value":false|...
    E0830 19:07:50.019669 1 reflector.go:153] pkg/mod/k8s.io/client-go@v0.17.2/tools/cache/reflector.go:105: Failed to list
    v1alpha1.Component: v1alpha1.ComponentList.Items: []v1alpha1.Component: v1alpha1.Component.Spec: v1alpha1.ComponentSpec.Metadata: []v1alpha1.MetadataItem: v1alpha1.MetadataItem.Value: ReadString: expects " or n, but found 6, error found in #10 byte of ...|,"value":60},{"name"|..., bigger context ...|gqc7ypnZUV4Ixw="},{"name":"timeoutInSec","value":60},{"name":"disableEntityManagement","value":false|...
    E0830 19:07:51.022027 1 reflector.go:15
    I see now there is version 0.10, this was working fine 2 weeks back when version was 0.9 . Is there a way that I can use specify version during helm chart installation as I am using helm to install dapr
    Ravindra
    @Ravindra-a
    My main issue is I have configured pub-sub using Azure Service Bus, however when I am publishing anything to service bus although it gets posted to the sidecar it doesn't gets posted to the Service bus
    when I check logs for my pod I see this
    {"app_id":"notification","instance":"<redacted>","level":"info","msg":"mTLS is disabled. Skipping certificate request and tls validation","scope":"dapr.runtime","time":"2020-08-30T19:03:27.049587447Z","type":"log","ver":"0.10.0"}
    {"app_id":"notification","instance":"<redacted>","level":"warning","msg":"failed to load components: rpc error: code = Unavailable desc = connection error: desc = \"transport: Error while dialing dial tcp 10.0.120.180:80: connect: connection refused\"","scope":"dapr.runtime","time":"2020-08-30T19:03:36.068384958Z","type":"log","ver":"0.10.0"}
    Ravindra
    @Ravindra-a
    finally figured out my issue, something is definitely wrong in 0.10.0, so used --set global.tag=0.9.0. Eventually there wasn't any error in logs, however none of my components were getting detected so have to install everything in same namespace, including core dapr components. Found this link talking something about scopes - dapr/dapr#1181 . Is it necessary to have everything within same namespace ?
    19 replies
    Yaron Schneider
    @yaron2
    hey @Ravindra-a, I responded in a new thread on your latest message.
    Tugay Ersoy
    @Admiralkheir
    Hi, I have a problem with rabbitMQ, Running 2 service on my local machine with local dapr, all have a different port (grpc, metrics, etc) one service published event then subscriber triggering and returning 500 (for testing pub/sub mechanism) after that I restarted and didn't notice any triggering for my subscriber, I edited yaml component like this
    apiVersion: dapr.io/v1alpha1
    kind: Component
    metadata:
      name: messagebus
      namespace: default
    spec:
      type: pubsub.rabbitmq
      metadata:
      - name: host
        value: amqp://localhost:5672 # Required. Example: "amqp://rabbitmq.default.svc.cluster.local:5672", "amqp://localhost:5672"
      - name: consumerID
        value: rabbitMqConsumer # Required. Any unique ID. Example: "myConsumerID"
      # - name: durable
      #   value: "true" # Optional. Default: "false"
      # # - name: deletedWhenUnused
      # #   value: <REPLACE-WITH-DELETE-WHEN-UNUSED> # Optional. Default: "false"
      - name: autoAck
        value: "true" # Optional. Default: "false"
      # # - name: deliveryMode
      # #   value: "0" # Optional. Default: "0". Values between 0 - 2.
      # - name: requeueInFailure
      #   value: "true" # Optional. Default: "false".