This project is a lightweight host that allows developers to run cloud-native workflows locally, on-premises or any cloud environment using theAzure Logic Appsworkflow engine andDapr.
This project is now archived and transferred to the fork under the Azure organization in GitHub:https://github /Azure/dapr-logicapps-extension |
Watch thisvideofor overview of Dapr Workflows.
By using a workflow engine, business logic can be defined in a declarative, no-code fashion so application code doesn't need to change when a workflow changes. Dapr Workflows allows you to use workflows in a distributed application along with these added benefits:
- Run workflows anywhere - on your local machine, on-premises, on Kubernetes or in the cloud
- Built-in tracing, metrics and mTLS through Dapr
- gRPC and HTTP endpoints for your workflows
- Kick off workflows based on Dapr bindings events
- Orchestrate complex workflows by calling back to Dapr to save state, publish a message and more
New to Dapr? Learn more about Dapr withthis overview
Dapr Workflows hosts a gRPC server that implements the Dapr Client API.
This allows users to start workflows using gRPC and HTTP endpoints through Dapr, or start a workflow asynchronously using Dapr bindings. Once a workflow request comes in, Dapr Workflows uses the Logic Apps SDK to execute the workflow.
Dapr Workflows can be used as the orchestrator for many otherwise complex activities. For example, invoking an external endpoint, saving the data to a state store, publishing the result to a different app or invoking a binding can all be done by calling back into Dapr from the workflow itself.
This is due to the fact Dapr runs as a sidecar next to the workflow host just as if it was any other app.
Examineworkflow2.jsonas an example of a workflow that does the following:
- Calls into Azure Functions to get a JSON response
- Saves the result to a Dapr state store
- Sends the result to a Dapr binding
- Returns the result to the caller
Since Dapr supports many pluggable state stores and bindings, the workflow becomes portable between different environments (cloud, edge or on-premises) without the user changing the code -because there is no code involved.
Prerequisites:
- Install theDapr CLI
- Azure Blob Storage Account
Supported Dapr Version: 0.10.0 and above
Once you have the Dapr CLI installed, run:
dapr init
First, set up the environment variables containing the Azure Storage Account credentials:
Mac / Linux
exportSTORAGE_ACCOUNT_KEY=<YOUR-STORAGE-ACCOUNT-KEY>
exportSTORAGE_ACCOUNT_NAME=<YOUR-STORAGE-ACCOUNT-NAME>
Windows
setSTORAGE_ACCOUNT_KEY=<YOUR-STORAGE-ACCOUNT-KEY>
setSTORAGE_ACCOUNT_NAME=<YOUR-STORAGE-ACCOUNT-NAME>
cd src/Dapr.Workflows
dapr run --app-id workflows --protocol grpc --port 3500 --app-port 50003 -- dotnet run --workflows-path../../samples
curl http://localhost:3500/v1.0/invoke/workflows/method/workflow1
{ "value": "Hello from Logic App workflow running with Dapr!" }
Rejoice!
Make sure you have a running Kubernetes cluster andkubectl
in your path.
Once you have the Dapr CLI installed, run:
dapr init --kubernetes
Wait until the Dapr pods have the statusRunning
.
kubectl create configmap workflows --from-file./samples/workflow1.json
Replace the account name and key values below with the actual credentials:
kubectl create secret generic dapr-workflows --from-literal=accountName=<YOUR-STORAGE-ACCOUNT-NAME> --from-literal=accountKey=<YOUR-STORAGE-ACCOUNT-KEY>
kubectl apply -f deploy/deploy.yaml
Create a port-forward to the dapr workflows container:
kubectl port-forward deploy/dapr-workflows-host 3500:3500
Now, invoke logic apps through Dapr:
curl http://localhost:3500/v1.0/invoke/workflows/method/workflow1
{ "value": "Hello from Logic App workflow running with Dapr!" }
Rejoice once more!
First, create any Dapr binding of your choice.
SeethisHow-To tutorial andsampleto get started.
In order for Dapr Workflows to be able to start a workflow from a Dapr binding event, simply name the binding with the name of the workflow you want it to trigger. Couldn't get any simpler!
Here's an example of a Kafka binding that will trigger a workflow namedworkflow1
:
apiVersion:dapr.io/v1 Alpha 1
kind:Component
metadata:
name:workflow1
spec:
type:bindings.kafka
metadata:
-name:topics
value:topic1
-name:brokers
value:localhost:9092
-name:consumerGroup
value:group1
-name:authRequired
value:"false"
Place the binding yaml file above in acomponents
directory at the root of your application.
kubectl apply -f my_binding.yaml
Once an event is sent to the bindings component, check the logs Dapr Workflows to see the output.
In standalone mode, the output will be printed to the local terminal.
On Kubernetes, run the following command:
kubectl logs -l app=dapr-workflows-host -c host
Make sure you have dotnet core installed on your machine. At minimum, you need.NET Core SDK 3.1to build.
- Clone the repo
- Inside the top level dir, run:
dotnet build
Make sure you have Docker installed on your machine.
Compile to release mode:
dotnet publish -c Release -r linux-x64 --self-contained false
Build image:
docker build -t <registry>/<image>.
Push image:
docker push <registry>/<image>