/kubecon-na-2022-dapr

DAPR demo

Primary LanguageJavaApache License 2.0Apache-2.0

Dapr's Pluggable Components Example for KubeCon NA 2022

Pre-requisites

Common:

For memstore example:

For Discord binding example:

For Kubernetes examples:

For sentiment analysis component in Azure:

  • Endpoint and Key for Azure's Cognitive Service for Language:

Clone this repo:

git clone git@github.com:artursouza/kubecon-na-2022.git
cd kubecon-na-2022

Standalone mode

State store example

Run the in-memory store pluggable component:

cd pluggable-components/memstore
dotnet run

In a new terminal, let's create a component using the new memstore type.

mv ~/.dapr/components/statestore.yaml ~/.dapr/components/statestore.yam_
cat > ~/.dapr/components/statestore.yaml
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: statestore
spec:
  type: state.memstore
  version: v1
  metadata:

Now, statestore is using state.memstore instead of state.redis. We will use a existing Dapr tutorial to show it in use.

cd ../../../
git clone -b v1.8.0 git@github.com:dapr/quickstarts.git
cd quickstarts/tutorials/hello-world/node
npm install

Run the node app:

dapr run --app-id nodeapp --app-port 3000 --dapr-http-port 3500 node app.js

In a new terminal, invoke the service:

dapr invoke --app-id nodeapp --method neworder --data-file sample.json

Now, go to the first terminal, running the pluggable components and see the log output:

info: DaprMemStoreComponent.Services.MemStoreService[0]
      Init request for memstore
info: DaprMemStoreComponent.Services.MemStoreService[0]
      BulkSet request for 1 keys
info: DaprMemStoreComponent.Services.MemStoreService[0]
      BulkSet request for key nodeapp||order

Input binding example

Run the Discord input binding component:

First, get a token for a bot in Discord. Then, export it as an environment variable:

export DISCORD_TOKEN=<TOKEN_GOES_HERE>

Run the Discord input binding component:

cd pluggable-components/discord-binding
mvn clean install
java -jar ./target/dapr-discord-binding-0.0.1-jar-with-dependencies.jar

In a new terminal, run an app that receives events via binding (at the root folder of this repository):

dapr run --app-id binding-app --app-port 3000 --components-path=./components/ -- npx http-echo-server 3000

Now, go to a channel where your bot is in and send any message. You should see the same message echoed in the terminal above.

Kubernetes mode

Setup Minikube:

make minikube-start

Init Dapr:

dapr init -k

Monitor state of Dapr control plane:

dapr status -k

State store example

Deploy:

kubectl apply -f kubernetes/memstore-example/

Now, watch for pods to be deployed. Notice that the nodeapp has 3 containes and not 2. One is the app, 2nd is the sidecar and 3rd is the memstore pluggable component:

kubectl get pods -w

Now, see the logs for the node app and the memstore component:

kubectl logs service/nodeapp node
kubectl logs service/nodeapp memstore

Clean up:

kubectl delete -f kubernetes/memstore-example/

Discord binding example

Install Redis:

helm install redis bitnami/redis --set image.tag=6.2

Create Kubernetes secret for Discord's token, based of the environment variable created previously:

kubectl create secret generic discord --from-literal=token=$DISCORD_TOKEN

Create Kubernetes secrets for the endpoint and key for Azure Cognitive Services:

kubectl create secret generic azure-cognitiveservices-endpoint --from-literal=value=https://<YOUR_ENDPOINT_ALIAS>.cognitiveservices.azure.com/
kubectl create secret generic azure-cognitiveservices-subscriptionkey --from-literal=value=<YOUR_KEY_GOES_HERE>

Deploy:

kubectl apply -f kubernetes/discord-example/

Watch for pods being deployed:

kubectl get pods -w

After all PODs are running, forward the web app port:

kubectl port-forward services/viewer 8080:80

Then, open http://localhost:8080/

Now, you can open the Discord channel and post messages. Those will show up on the web app with the sentiment analysis icon next to it.