dapr
/
quickstarts
mirror of https://github.com/dapr/quickstarts.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into sdkupdate

This commit is contained in:
Elena Kolevska 2025-03-04 17:13:29 +00:00 committed by GitHub
parent 0d34aa2272 43a98a10a0
commit 6816ba4803
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 19 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
jobs/csharp/http/job-scheduler/Program.cs
View File

@ -18,7 +18,7 @@ var r2d2JobBody = new
}; };
var daprHost = Environment.GetEnvironmentVariable("DAPR_HOST") ?? "http://localhost"; var daprHost = Environment.GetEnvironmentVariable("DAPR_HOST") ?? "http://localhost";
var schedulerDaprHttpPort = "6280"; var jobServiceDaprHttpPort = "6280";
var httpClient = new HttpClient(); var httpClient = new HttpClient();
@ -48,7 +48,7 @@ catch (Exception ex)
async Task ScheduleJob(string jobName, object jobBody) async Task ScheduleJob(string jobName, object jobBody)
{ {
var reqURL = $"{daprHost}:{schedulerDaprHttpPort}/v1.0-alpha1/jobs/{jobName}"; var reqURL = $"{daprHost}:{jobServiceDaprHttpPort}/v1.0-alpha1/jobs/{jobName}";
var jsonBody = JsonSerializer.Serialize(jobBody); var jsonBody = JsonSerializer.Serialize(jobBody);
var content = new StringContent(jsonBody, Encoding.UTF8, "application/json"); var content = new StringContent(jsonBody, Encoding.UTF8, "application/json");
@ -64,7 +64,7 @@ async Task ScheduleJob(string jobName, object jobBody)
async Task GetJobDetails(string jobName) async Task GetJobDetails(string jobName)
{ {
var reqURL = $"{daprHost}:{schedulerDaprHttpPort}/v1.0-alpha1/jobs/{jobName}"; var reqURL = $"{daprHost}:{jobServiceDaprHttpPort}/v1.0-alpha1/jobs/{jobName}";
var response = await httpClient.GetAsync(reqURL); var response = await httpClient.GetAsync(reqURL);

8
jobs/go/http/job-scheduler/job-scheduler.go
View File

@ -35,7 +35,7 @@ func main() {
daprHost = "http://localhost" daprHost = "http://localhost"
} }
schedulerDaprHttpPort := "6280" jobServiceDaprHttpPort := "6280"
client := http.Client{ client := http.Client{
Timeout: 15 * time.Second, Timeout: 15 * time.Second,
@ -43,7 +43,7 @@ func main() {
// Schedule a job using the Dapr Jobs API with short dueTime // Schedule a job using the Dapr Jobs API with short dueTime
jobName := "R2-D2" jobName := "R2-D2"
reqURL := daprHost + ":" + schedulerDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName reqURL := daprHost + ":" + jobServiceDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName
req, err := http.NewRequest("POST", reqURL, strings.NewReader(r2d2JobBody)) req, err := http.NewRequest("POST", reqURL, strings.NewReader(r2d2JobBody))
if err != nil { if err != nil {
@ -71,7 +71,7 @@ func main() {
// Schedule a job using the Dapr Jobs API with long dueTime // Schedule a job using the Dapr Jobs API with long dueTime
jobName = "C-3PO" jobName = "C-3PO"
reqURL = daprHost + ":" + schedulerDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName reqURL = daprHost + ":" + jobServiceDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName
req, err = http.NewRequest("POST", reqURL, strings.NewReader(c3poJobBody)) req, err = http.NewRequest("POST", reqURL, strings.NewReader(c3poJobBody))
if err != nil { if err != nil {
@ -93,7 +93,7 @@ func main() {
// Gets a job using the Dapr Jobs API // Gets a job using the Dapr Jobs API
jobName = "C-3PO" jobName = "C-3PO"
reqURL = daprHost + ":" + schedulerDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName reqURL = daprHost + ":" + jobServiceDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName
res, err = http.Get(reqURL) res, err = http.Get(reqURL)
if err != nil { if err != nil {

6
jobs/javascript/http/job-scheduler/index.js
View File

@ -13,7 +13,7 @@ const r2d2JobBody = {
dueTime: "15s", dueTime: "15s",
}; };
const daprHost = process.env.DAPR_HOST || "http://localhost"; const daprHost = process.env.DAPR_HOST || "http://localhost";
const schedulerDaprHttpPort = "6280"; const jobServiceDaprHttpPort = "6280";
async function main() { async function main() {
const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms)); const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));
@ -45,7 +45,7 @@ async function main() {
} }
async function scheduleJob(jobName, jobBody) { async function scheduleJob(jobName, jobBody) {
const reqURL = `${daprHost}:${schedulerDaprHttpPort}/v1.0-alpha1/jobs/${jobName}`; const reqURL = `${daprHost}:${jobServiceDaprHttpPort}/v1.0-alpha1/jobs/${jobName}`;
const response = await fetch(reqURL, { const response = await fetch(reqURL, {
method: "POST", method: "POST",
headers: { headers: {
@ -64,7 +64,7 @@ async function scheduleJob(jobName, jobBody) {
} }
async function getJobDetails(jobName) { async function getJobDetails(jobName) {
const reqURL = `${daprHost}:${schedulerDaprHttpPort}/v1.0-alpha1/jobs/${jobName}`; const reqURL = `${daprHost}:${jobServiceDaprHttpPort}/v1.0-alpha1/jobs/${jobName}`;
const response = await fetch(reqURL, { const response = await fetch(reqURL, {
method: "GET", method: "GET",
}); });

5
jobs/python/http/README.md
View File

@ -16,6 +16,11 @@ This quickstart includes two apps:
- [Dapr CLI](https://docs.dapr.io/getting-started/install-dapr-cli/) - [Dapr CLI](https://docs.dapr.io/getting-started/install-dapr-cli/)
- [Initialized Dapr environment](https://docs.dapr.io/getting-started/install-dapr-selfhost/) - [Initialized Dapr environment](https://docs.dapr.io/getting-started/install-dapr-selfhost/)
## Environment Variables
- `JOB_SERVICE_DAPR_HTTP_PORT`: The Dapr HTTP port of the job-service (default: 6280)
- `DAPR_HOST`: The Dapr host address (default: http://localhost)
## Install dependencies ## Install dependencies
<!-- STEP <!-- STEP

8
jobs/python/http/job-scheduler/app.py
View File

@ -55,18 +55,18 @@ def main():
time.sleep(5) time.sleep(5)
dapr_host = os.getenv('DAPR_HOST', 'http://localhost') dapr_host = os.getenv('DAPR_HOST', 'http://localhost')
scheduler_dapr_http_port = os.getenv('SCHEDULER_DAPR_HTTP_PORT', '6280') job_service_dapr_http_port = os.getenv('JOB_SERVICE_DAPR_HTTP_PORT', '6280')
# Schedule R2-D2 job # Schedule R2-D2 job
schedule_job(dapr_host, scheduler_dapr_http_port, "R2-D2", R2D2_JOB_BODY) schedule_job(dapr_host, job_service_dapr_http_port, "R2-D2", R2D2_JOB_BODY)
time.sleep(5) time.sleep(5)
# Schedule C-3PO job # Schedule C-3PO job
schedule_job(dapr_host, scheduler_dapr_http_port, "C-3PO", C3PO_JOB_BODY) schedule_job(dapr_host, job_service_dapr_http_port, "C-3PO", C3PO_JOB_BODY)
time.sleep(5) time.sleep(5)
# Get C-3PO job details # Get C-3PO job details
get_job_details(dapr_host, scheduler_dapr_http_port, "C-3PO") get_job_details(dapr_host, job_service_dapr_http_port, "C-3PO")
time.sleep(5) time.sleep(5)
if __name__ == "__main__": if __name__ == "__main__":