Added Dapr Jobs .NET Quickstart #1131
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,10 @@ | ||
| <Project Sdk="Microsoft.NET.Sdk.Web"> | ||
|
|
||
| <PropertyGroup> | ||
| <OutputType>Exe</OutputType> | ||
| <TargetFramework>net9.0</TargetFramework> | ||
| <ImplicitUsings>enable</ImplicitUsings> | ||
| <Nullable>enable</Nullable> | ||
| </PropertyGroup> | ||
|
|
||
| </Project> | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,21 @@ | ||
| var builder = WebApplication.CreateBuilder(args); | ||
|
|
||
| var app = builder.Build(); | ||
|
|
||
| app.MapGet("/etl/{taskId}", async (ILogger<Program> logger, Guid taskId) => | ||
| { | ||
| Log.LogEtlStart(logger, taskId); | ||
|
|
||
| //Simulate running some sort of ETL operation | ||
| await Task.Delay(TimeSpan.FromSeconds(7)); | ||
|
|
||
| return TypedResults.Ok; | ||
| }); | ||
|
|
||
| await app.RunAsync(); | ||
|
|
||
| static partial class Log | ||
| { | ||
| [LoggerMessage(LogLevel.Information, "Starting task {taskId} on service")] | ||
| public static partial void LogEtlStart(ILogger logger, Guid taskId); | ||
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,28 @@ | ||
| | ||
| Microsoft Visual Studio Solution File, Format Version 12.00 | ||
| # Visual Studio Version 17 | ||
| VisualStudioVersion = 17.0.31903.59 | ||
| MinimumVisualStudioVersion = 10.0.40219.1 | ||
| Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "JobsApp", "JobsApp/JobsApp.csproj", "{4F0E7704-CB1D-48E8-A357-9E33FB7003D5}" | ||
| EndProject | ||
| Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "EtlService", "EtlService\EtlService.csproj", "{797B142F-3AA3-4EEF-B718-227AEADED508}" | ||
| EndProject | ||
| Global | ||
| GlobalSection(SolutionConfigurationPlatforms) = preSolution | ||
| Debug|Any CPU = Debug|Any CPU | ||
| Release|Any CPU = Release|Any CPU | ||
| EndGlobalSection | ||
| GlobalSection(SolutionProperties) = preSolution | ||
| HideSolutionNode = FALSE | ||
| EndGlobalSection | ||
| GlobalSection(ProjectConfigurationPlatforms) = postSolution | ||
| {4F0E7704-CB1D-48E8-A357-9E33FB7003D5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU | ||
| {4F0E7704-CB1D-48E8-A357-9E33FB7003D5}.Debug|Any CPU.Build.0 = Debug|Any CPU | ||
| {4F0E7704-CB1D-48E8-A357-9E33FB7003D5}.Release|Any CPU.ActiveCfg = Release|Any CPU | ||
| {4F0E7704-CB1D-48E8-A357-9E33FB7003D5}.Release|Any CPU.Build.0 = Release|Any CPU | ||
| {797B142F-3AA3-4EEF-B718-227AEADED508}.Debug|Any CPU.ActiveCfg = Debug|Any CPU | ||
| {797B142F-3AA3-4EEF-B718-227AEADED508}.Debug|Any CPU.Build.0 = Debug|Any CPU | ||
| {797B142F-3AA3-4EEF-B718-227AEADED508}.Release|Any CPU.ActiveCfg = Release|Any CPU | ||
| {797B142F-3AA3-4EEF-B718-227AEADED508}.Release|Any CPU.Build.0 = Release|Any CPU | ||
| EndGlobalSection | ||
| EndGlobal |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,15 @@ | ||
| <Project Sdk="Microsoft.NET.Sdk.Web"> | ||
|
|
||
| <PropertyGroup> | ||
| <OutputType>Exe</OutputType> | ||
| <TargetFramework>net9.0</TargetFramework> | ||
WhitWaldo marked this conversation as resolved.
Show resolved
Hide resolved
|
||
| <ImplicitUsings>enable</ImplicitUsings> | ||
| <Nullable>enable</Nullable> | ||
| </PropertyGroup> | ||
|
|
||
| <ItemGroup> | ||
| <PackageReference Include="Dapr.AspNetCore" Version="1.15.0-rc02" /> | ||
| <PackageReference Include="Dapr.Jobs" Version="1.15.0-rc02" /> | ||
| </ItemGroup> | ||
|
|
||
| </Project> | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,3 @@ | ||
| namespace JobsApp.Models; | ||
|
|
||
| internal sealed record JobEtlPayload(string AppId, string TaskId); |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,67 @@ | ||
| using System.Text.Json; | ||
| using Dapr.Client; | ||
| using Dapr.Jobs; | ||
| using Dapr.Jobs.Extensions; | ||
| using Dapr.Jobs.Models; | ||
| using Dapr.Jobs.Models.Responses; | ||
| using JobsApp.Models; | ||
|
|
||
| // The jobs host is a background service that connects to the sidecar over gRPC | ||
| var builder = WebApplication.CreateBuilder(args); | ||
|
|
||
| builder.Services.AddDaprClient(); | ||
| builder.Services.AddDaprJobsClient(); | ||
|
|
||
| var app = builder.Build(); | ||
|
|
||
| //Set up a handler to capture incoming jobs | ||
| var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(60)); | ||
| app.MapDaprScheduledJobHandler(async ( | ||
| string? jobName, | ||
| DaprJobDetails? jobDetails, | ||
| ILogger? logger, | ||
| DaprClient daprClient, | ||
| CancellationToken cancellationToken) => | ||
| { | ||
| var payload = JsonSerializer.Deserialize<JobEtlPayload>(jobDetails?.Payload); | ||
|
|
||
| if (logger is not null) | ||
| Log.LogJobInvocation(logger, jobName, payload); | ||
|
|
||
| if (payload is null) | ||
| { | ||
| if (logger is not null) | ||
| Log.LogPaylodNotAvailable(logger); | ||
| throw new Exception("Unable to deserialize the payload from the scheduled job invocation"); | ||
| } | ||
|
|
||
| await daprClient.InvokeMethodAsync(HttpMethod.Get, "etl-svc", $"/etl/{payload.TaskId}", cancellationToken); | ||
|
There was a problem hiding this comment. what do you think about using the "http proxy" approach to invoking the http call instead like we do in the basic service invoke quickstart? https://docs.dapr.io/getting-started/quickstarts/serviceinvocation-quickstart/ that shows you can keep using your favorite HTTP client and just pass a header, making dapr look a bit more familiar. There was a problem hiding this comment. Also can we sync to There was a problem hiding this comment. As this was the SDK quickstart, I opted to use the SDK-style service invocation instead of A sync to release-1.15 does not appear to be in the cards for me until all my PRs are closed. As best I can tell I'm going to have to delete my GitHub fork and re-create it to get it to sync anything but master (as it's the only branch I originally forked). There was a problem hiding this comment. We are deprecating the InvokeMethodAsync calls fyi! There was a problem hiding this comment. @alicejgibbons Where are they being deprecated at? That's an SDK-level helper method to assist in making service invocation calls. The runtime shouldn't really be aware of them as they just show up as GET or POST requests. There was a problem hiding this comment. Sooooo, maybe dotnet is already doing this but we need to be using the native HTTP clients in each respective language instead of the dapr created ones. Question - is adding the Dapr client into builder effectively the same as the following? |
||
| }, cancellationTokenSource.Token); | ||
|
|
||
| //Schedule with the Dapr Jobs client | ||
| var jobsClient = app.Services.GetRequiredService<DaprJobsClient>(); | ||
| var logger = app.Services.GetRequiredService<ILogger<Program>>(); | ||
|
|
||
| //Create a Cron expression to run four times a minute on the 15-second marks | ||
| var cronBuilder = new CronExpressionBuilder() | ||
| .On(OnCronPeriod.Second, 15); | ||
|
|
||
| //Schedule ETL job to run for only four invocations | ||
| var payload = new JobEtlPayload("etl-svc", "op-109780792"); | ||
| const string nameOfJob = "daily-etl"; | ||
| await jobsClient.ScheduleJobWithPayloadAsync(nameOfJob, DaprJobSchedule.FromCronExpression(cronBuilder), payload, DateTime.Now, 4); | ||
| Log.LogJobSchedule(logger, nameOfJob, payload); | ||
|
|
||
| await app.RunAsync(); | ||
|
|
||
| static partial class Log | ||
| { | ||
| [LoggerMessage(LogLevel.Information, "Scheduled job '{jobName}' with payload {payload}")] | ||
| public static partial void LogJobSchedule(ILogger logger, string jobName, JobEtlPayload payload); | ||
|
|
||
| [LoggerMessage(LogLevel.Information, "Unable to deserialize the payload from the scheduled job invocation")] | ||
| public static partial void LogPaylodNotAvailable(ILogger logger); | ||
|
|
||
| [LoggerMessage(LogLevel.Information, "ETL job invoked: {jobName} with payload {payload}")] | ||
| public static partial void LogJobInvocation(ILogger logger, string? jobName, JobEtlPayload? payload); | ||
| } | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,127 @@ | ||
| # Dapr jobs | ||
|
|
||
| In this quickstart, you'll create two microservices that demonstrate how the Jobs API can be readily utilized in | ||
| a .NET application. The Jobs App will schedule the job and will handle its invocation when triggered, sending a | ||
| message to another microservice to simulate some sort of operation. | ||
|
|
||
| Visit [this link](https://docs.dapr.io/developing-applications/building-blocks/jobs/jobs-overview/) for more | ||
| information about the Dapr Jobs API. | ||
|
|
||
| This quickstart includes the following two services: | ||
| - Schedules Jobs and handles job invocations: `JobsApp` | ||
| - Receives service invocation and simulates ETL operation: `EtlService` | ||
|
|
||
| ## Run the quickstart | ||
| 1. Open a new terminal window and launch the ETL service with the following command: | ||
|
|
||
| <!-- STEP | ||
| name: Run ETL service | ||
| expected_stdout_lines: | ||
| - 'Starting Dapr with id etl-svc.' | ||
| - 'Updating metadata for app command: dotnet run --project ./EtlService/EtlService.csproj --urls=http://localhost:5001' | ||
| - 'You're up and running! Both Dapr and your app logs will appear here.' | ||
| output_match_mode: substring | ||
| match_order: none | ||
| background: true | ||
| sleep: 15 | ||
| timeout_seconds: 45 | ||
| --> | ||
|
|
||
| ```bash | ||
| dapr run --app-id etl-svc -- dotnet run --project ./EtlService/EtlService.csproj --urls=http://localhost:5001 | ||
| ``` | ||
| The terminal console should show standard startup logs like the following since the app will start, but then wait until | ||
| the service is invoked: | ||
|
|
||
| ```text | ||
| Starting Dapr with id etl-svc. HTTP Port: 50737. gRPC Port: 50738 | ||
| Checking if Dapr sidecar is listening on HTTP port 50737 | ||
| Flag --components-path has been deprecated, use --resources-path | ||
| Flag --dapr-http-max-request-size has been deprecated, use '--max-body-size 4Mi' | ||
| Flag --dapr-http-read-buffer-size has been deprecated, use '--read-buffer-size 4Ki' | ||
| time="2025-01-15T09:44:15.8139364-06:00" level=info msg="Starting Dapr Runtime -- version 1.15.0-rc.1 -- commit fdd642e96ac06163b30ef1db751a403351887dc9" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8139364-06:00" level=info msg="Log level set to: info" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8139364-06:00" level=warning msg="mTLS is disabled. Skipping certificate request and tls validation" app_id=etl-svc instance=Incubus scope=dapr.runtime.security type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8155037-06:00" level=info msg="metric spec: {\"enabled\":true}" app_id=etl-svc instance=Incubus scope=dapr.runtime.diagnostics type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8155037-06:00" level=info msg="Using default latency distribution buckets: [1 2 3 4 5 6 8 10 13 16 20 25 30 40 50 65 80 100 130 160 200 250 300 400 500 650 800 1000 2000 5000 10000 20000 50000 100000]" app_id=etl-svc instance=Incubus scope=dapr.runtime.diagnostics type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8155037-06:00" level=warning msg="The default value for 'spec.metric.http.increasedCardinality' will change to 'false' in Dapr 1.15 or later" app_id=etl-svc instance=Incubus scope=dapr.runtime.diagnostics type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8164977-06:00" level=info msg="standalone mode configured" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8164977-06:00" level=info msg="app id: etl-svc" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8171436-06:00" level=info msg="Scheduler client initialized for address: localhost:6060" app_id=etl-svc instance=Incubus scope=dapr.runtime.scheduler.clients type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8171436-06:00" level=info msg="Scheduler clients initialized" app_id=etl-svc instance=Incubus scope=dapr.runtime.scheduler.clients type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8171436-06:00" level=info msg="Dapr trace sampler initialized: ParentBased{root:AlwaysOnSampler,remoteParentSampled:AlwaysOnSampler,remoteParentNotSampled:AlwaysOffSampler,localParentSampled:AlwaysOnSampler,localParentNotSampled:AlwaysOffSampler}" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8171436-06:00" level=info msg="metrics server started on :50739/" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8483454-06:00" level=info msg="local service entry announced: etl-svc -> 192.168.2.38:50740" app_id=etl-svc component="nr (mdns/v1)" instance=Incubus scope=dapr.contrib type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8539638-06:00" level=info msg="Initialized name resolution to mdns" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8545343-06:00" level=info msg="Loading components…" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8556398-06:00" level=info msg="Waiting for all outstanding components to be processed…" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8556398-06:00" level=info msg="All outstanding components processed" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8561666-06:00" level=info msg="Loading endpoints…" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.856722-06:00" level=info msg="Waiting for all outstanding http endpoints to be processed…" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.856722-06:00" level=info msg="All outstanding http endpoints processed" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.856722-06:00" level=info msg="Loading Declarative Subscriptions…" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8572499-06:00" level=warning msg="App channel is not initialized. Did you configure an app-port?" app_id=etl-svc instance=Incubus scope=dapr.runtime.channels type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8577923-06:00" level=info msg="gRPC server listening on TCP address: :50738" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.api type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8577923-06:00" level=info msg="Enabled gRPC tracing middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.api type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8577923-06:00" level=info msg="Enabled gRPC metrics middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.api type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8583182-06:00" level=info msg="Registering workflow engine for gRPC endpoint: [::]:50738" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.api type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8583182-06:00" level=info msg="API gRPC server is running on port 50738" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8583182-06:00" level=warning msg="The default value for 'spec.metric.http.increasedCardinality' will change to 'false' in Dapr 1.15 or later" app_id=etl-svc instance=Incubus scope=dapr.runtime.http type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8583182-06:00" level=info msg="Enabled max body size HTTP middleware with size 4194304 bytes" app_id=etl-svc instance=Incubus scope=dapr.runtime.http type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8588281-06:00" level=info msg="Enabled tracing HTTP middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.http type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8588281-06:00" level=info msg="Enabled metrics HTTP middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.http type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8595557-06:00" level=info msg="HTTP server listening on TCP address: :50737" app_id=etl-svc instance=Incubus scope=dapr.runtime.http type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8595557-06:00" level=info msg="HTTP server is running on port 50737" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8595557-06:00" level=info msg="The request body size parameter is: 4194304 bytes" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.860102-06:00" level=info msg="gRPC server listening on TCP address: :50740" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.internal type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.860102-06:00" level=info msg="Enabled gRPC tracing middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.internal type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.860102-06:00" level=info msg="Enabled gRPC metrics middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.internal type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.860102-06:00" level=info msg="Internal gRPC server is running on :50740" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8606266-06:00" level=info msg="actors: state store is not configured - this is okay for clients but services with hosted actors will fail to initialize!" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8611851-06:00" level=info msg="Configuring actors placement provider 'placement'. Configuration: 'placement:localhost:6050'" app_id=etl-svc instance=Incubus scope=dapr.runtime.actor type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8611851-06:00" level=info msg="Configuring actor reminders provider 'default'. Configuration: ''" app_id=etl-svc instance=Incubus scope=dapr.runtime.actor type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8611851-06:00" level=info msg="Actor runtime started. Idle timeout: 1h0m0s" app_id=etl-svc instance=Incubus scope=dapr.runtime.actor type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8616921-06:00" level=info msg="Configuring workflow engine with actors backend" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8617175-06:00" level=info msg="Registering component for dapr workflow engine..." app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8617175-06:00" level=info msg="Initializing Dapr workflow component" app_id=etl-svc component="dapr (workflow.dapr/v1)" instance=Incubus scope=dapr.contrib type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8617175-06:00" level=info msg="Workflow engine initialized." app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.862781-06:00" level=info msg="dapr initialized. Status: Running. Init Elapsed 46ms" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8627966-06:00" level=info msg="Scheduler stream connected" app_id=etl-svc instance=Incubus scope=dapr.runtime.scheduler type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8924449-06:00" level=info msg="Actor API level in the cluster has been updated to 10" app_id=etl-svc instance=Incubus scope=dapr.runtime.actor type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8924449-06:00" level=info msg="Placement tables updated, version: 9" app_id=etl-svc instance=Incubus scope=dapr.runtime.actors.placement type=log ver=1.15.0-rc.1 | ||
| Checking if Dapr sidecar is listening on GRPC port 50738 | ||
| Dapr sidecar is up and running. | ||
| Updating metadata for appPID: 41396 | ||
| Updating metadata for app command: dotnet run --project ./EtlService/EtlService.csproj --urls=http://localhost:5001 | ||
| You're up and running! Both Dapr and your app logs will appear here. | ||
| ``` | ||
|
|
||
| 2. Open a second terminal window and launch the Jobs app with the following command: | ||
|
|
||
| <!-- STEP | ||
| name: Run Jobs App service | ||
| expected-stdout_lines: | ||
| - 'Starting Dapr with id job-app.' | ||
| - 'Updating metadata for app command: dotnet run --project ./JobsApp/JobsApp.csproj --urls=http://localhost:5002' | ||
| - 'You're up and running! Both Dapr and your app logs will appear here.' | ||
| output_match_mode: substring | ||
| match_order: none | ||
| background: true | ||
| sleep: 15 | ||
| timeout_seconds: 45 | ||
| --> | ||
|
|
||
| ```bash | ||
| dapr run --app-id jobs-app -- dotnet run --project ./JobsApp/JobsApp.csproj --urls=http://localhost:5002 | ||
| ``` | ||
|
|
||
| As with the other application, the terminal console should show standard startup logs, but will then proceed to show your | ||
| application logs as the job is scheduled: | ||
|
|
||
| ```text | ||
| You're up and running! Both Dapr and your app logs will appear here. | ||
|
|
||
|
|
||
| ``` | ||
|
|
||
| 3. When you're finished, hit Ctrl + C in both terminals to stop and clean up the application processes |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,2 @@ | ||
| include ../../../docker.mk | ||
| include ../../../validate.mk |
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.