146 lines
10 KiB
Markdown
146 lines
10 KiB
Markdown
---
|
||
layout: default
|
||
title: Job Scheduler
|
||
nav_order: 1
|
||
has_children: false
|
||
has_toc: false
|
||
redirect_from:
|
||
- /job-scheduler-plugin/index/
|
||
---
|
||
|
||
# Job Scheduler
|
||
|
||
The OpenSearch Job Scheduler plugin provides a framework that can be used to build schedules for common tasks performed on your cluster. You can use Job Scheduler’s Service Provider Interface (SPI) to define schedules for cluster management tasks such as taking snapshots, managing your data’s lifecycle, and running periodic jobs. Job Scheduler has a sweeper that listens for updated events on the OpenSearch cluster and a scheduler that manages when jobs run.
|
||
|
||
You can install the Job Scheduler plugin by following the standard [OpenSearch plugin installation]({{site.url}}{{site.baseurl}}/install-and-configure/install-opensearch/plugins/) process. The sample-extension-plugin example provided in the [Job Scheduler GitHub repository](https://github.com/opensearch-project/job-scheduler) provides a complete example of utilizing Job Scheduler when building a plugin. To define schedules, you build a plugin that implements the interfaces provided in the Job Scheduler library. You can schedule jobs by specifying an interval, or you can use a Unix cron expression such as `0 12 * * ?`, which runs at noon every day, to define a more flexible schedule.
|
||
|
||
## Building a plugin for Job Scheduler
|
||
|
||
OpenSearch plugin developers can extend the Job Scheduler plugin to schedule jobs to perform on the cluster. Jobs you can schedule include running aggregation queries against raw data, saving the aggregated data to a new index every hour, or continuing to monitor the shard allocation by calling the OpenSearch API and then posting the output to a webhook.
|
||
|
||
For examples of building a plugin that uses the Job Scheduler plugin, see the Job Scheduler [README](https://github.com/opensearch-project/job-scheduler/blob/main/README.md).
|
||
|
||
## Defining an endpoint
|
||
|
||
You can configure your plugin's API endpoint by referencing the [example](https://github.com/opensearch-project/job-scheduler/blob/main/sample-extension-plugin/src/main/java/org/opensearch/jobscheduler/sampleextension/SampleExtensionRestHandler.java) `SampleExtensionRestHandler.java` file. Set the endpoint URL that your plugin will expose with `WATCH_INDEX_URI`:
|
||
|
||
```java
|
||
public class SampleExtensionRestHandler extends BaseRestHandler {
|
||
public static final String WATCH_INDEX_URI = "/_plugins/scheduler_sample/watch";
|
||
```
|
||
|
||
You can define the job configuration by [extending](https://github.com/opensearch-project/job-scheduler/blob/main/sample-extension-plugin/src/main/java/org/opensearch/jobscheduler/sampleextension/SampleJobParameter.java) `ScheduledJobParameter`. You can also define the fields used by your plugin, like `indexToWatch`, as shown in the [example](https://github.com/opensearch-project/job-scheduler/blob/main/sample-extension-plugin/src/main/java/org/opensearch/jobscheduler/sampleextension/SampleJobParameter.java) `SampleJobParameter` file. This job configuration will be saved as a document in an index you define, as shown in [this example](https://github.com/opensearch-project/job-scheduler/blob/main/sample-extension-plugin/src/main/java/org/opensearch/jobscheduler/sampleextension/SampleExtensionPlugin.java#L54).
|
||
|
||
## Configuring parameters
|
||
|
||
You can configure your plugin's parameters by referencing the [example](https://github.com/opensearch-project/job-scheduler/blob/main/sample-extension-plugin/src/main/java/org/opensearch/jobscheduler/sampleextension/SampleJobParameter.java) `SampleJobParameter.java` file and modifying it to fit your needs:
|
||
|
||
```java
|
||
/**
|
||
* A sample job parameter.
|
||
* <p>
|
||
* It adds an additional "indexToWatch" field to {@link ScheduledJobParameter}, which stores the index
|
||
* the job runner will watch.
|
||
*/
|
||
public class SampleJobParameter implements ScheduledJobParameter {
|
||
public static final String NAME_FIELD = "name";
|
||
public static final String ENABLED_FILED = "enabled";
|
||
public static final String LAST_UPDATE_TIME_FIELD = "last_update_time";
|
||
public static final String LAST_UPDATE_TIME_FIELD_READABLE = "last_update_time_field";
|
||
public static final String SCHEDULE_FIELD = "schedule";
|
||
public static final String ENABLED_TIME_FILED = "enabled_time";
|
||
public static final String ENABLED_TIME_FILED_READABLE = "enabled_time_field";
|
||
public static final String INDEX_NAME_FIELD = "index_name_to_watch";
|
||
public static final String LOCK_DURATION_SECONDS = "lock_duration_seconds";
|
||
public static final String JITTER = "jitter";
|
||
|
||
private String jobName;
|
||
private Instant lastUpdateTime;
|
||
private Instant enabledTime;
|
||
private boolean isEnabled;
|
||
private Schedule schedule;
|
||
private String indexToWatch;
|
||
private Long lockDurationSeconds;
|
||
private Double jitter;
|
||
```
|
||
|
||
Next, configure the request parameters you would like your plugin to use with Job Scheduler. These will be based on the variables you declare when configuring your plugin. The following example shows the request parameters you set when building your plugin:
|
||
|
||
```java
|
||
public SampleJobParameter(String id, String name, String indexToWatch, Schedule schedule, Long lockDurationSeconds, Double jitter) {
|
||
this.jobName = name;
|
||
this.indexToWatch = indexToWatch;
|
||
this.schedule = schedule;
|
||
|
||
Instant now = Instant.now();
|
||
this.isEnabled = true;
|
||
this.enabledTime = now;
|
||
this.lastUpdateTime = now;
|
||
this.lockDurationSeconds = lockDurationSeconds;
|
||
this.jitter = jitter;
|
||
}
|
||
|
||
@Override
|
||
public String getName() {
|
||
return this.jobName;
|
||
}
|
||
|
||
@Override
|
||
public Instant getLastUpdateTime() {
|
||
return this.lastUpdateTime;
|
||
}
|
||
|
||
@Override
|
||
public Instant getEnabledTime() {
|
||
return this.enabledTime;
|
||
}
|
||
|
||
@Override
|
||
public Schedule getSchedule() {
|
||
return this.schedule;
|
||
}
|
||
|
||
@Override
|
||
public boolean isEnabled() {
|
||
return this.isEnabled;
|
||
}
|
||
|
||
@Override
|
||
public Long getLockDurationSeconds() {
|
||
return this.lockDurationSeconds;
|
||
}
|
||
|
||
@Override public Double getJitter() {
|
||
return jitter;
|
||
}
|
||
```
|
||
|
||
The following table describes the request parameters configured in the previous example. All the request parameters shown are required.
|
||
|
||
| Field | Data type | Description |
|
||
:--- | :--- | :---
|
||
| getName | String | Returns the name of the job. |
|
||
| getLastUpdateTime | Time unit | Returns the time that the job was last run. |
|
||
| getEnabledTime | Time unit | Returns the time that the job was enabled. |
|
||
| getSchedule | Unix cron | Returns the job schedule formatted in Unix cron syntax. |
|
||
| isEnabled | Boolean | Indicates whether or not the job is enabled. |
|
||
| getLockDurationSeconds | Integer | Returns the duration of time for which the job is locked. |
|
||
| getJitter | Integer | Returns the defined jitter value. |
|
||
|
||
The logic used by your job should be defined by a class extended from `ScheduledJobRunner` in the `SampleJobParameter.java` sample file, such as `SampleJobRunner`. While the job is running, there is a locking mechanism you can use to prevent other nodes from running the same job. First, [acquire](https://github.com/opensearch-project/job-scheduler/blob/main/sample-extension-plugin/src/main/java/org/opensearch/jobscheduler/sampleextension/SampleJobRunner.java#L96) the lock. Then make sure to release the lock before the [job finishes](https://github.com/opensearch-project/job-scheduler/blob/main/sample-extension-plugin/src/main/java/org/opensearch/jobscheduler/sampleextension/SampleJobRunner.java#L116).
|
||
|
||
For more information, see the Job Scheduler [sample extension](https://github.com/opensearch-project/job-scheduler/blob/main/sample-extension-plugin/src/main/java/org/opensearch/jobscheduler/sampleextension/SampleJobParameter.java) directory in the [Job Scheduler GitHub repo](https://github.com/opensearch-project/job-scheduler).
|
||
|
||
## Job Scheduler cluster settings
|
||
|
||
The Job Scheduler plugin supports the following cluster settings. All settings are dynamic. To learn more about static and dynamic settings, see [Configuring OpenSearch]({{site.url}}{{site.baseurl}}/install-and-configure/configuring-opensearch/index/).
|
||
|
||
| Setting | Data type | Description |
|
||
:--- | :--- | :---
|
||
| `plugins.jobscheduler.jitter_limit` | Double | Defines the maximum delay multiplier for job execution time. Too many jobs starting at the same time can cause high resource consumption. To balance the load, you can add a random jitter delay to the start time. For example, if the time interval is 10 minutes and the jitter is 0.6, the next job run will be randomly delayed by a time period between 0 and 6 minutes. |
|
||
| `plugins.jobscheduler.request_timeout` | Time unit | The background sweep search timeout. Background sweep refers to the automatic scheduling and execution of registered jobs. It occurs on an interval and iterates through each extending plugin's registered job index, searching for jobs to be executed. |
|
||
| `plugins.jobscheduler.retry_count` | Integer | Used to define the retry count of an exponential backoff policy. Backoff policies determine how long bulk processors will wait before the bulk operation is retried. It is used whenever bulk indexing requests are impacted or rejected because of resource constraints at the time of a request. For the Job Scheduler plugin, this impacts searching registered job indexes. |
|
||
| `plugins.jobscheduler.sweeper.backoff_millis` | Time unit | Used to define the initial wait period of an exponential backoff policy, in milliseconds. Backoff policies determine how long bulk processors will wait before the bulk operation is retried. It is used whenever bulk indexing requests are impacted or rejected because of resource constraints at the time of a request. For the Job Scheduler plugin, this impacts searching registered job indexes. |
|
||
| `plugins.jobscheduler.sweeper.page_size` | Integer | Configures the search request used to find job documents within a registered job index. Defines the number of search hits to return. |
|
||
| `plugins.jobscheduler.sweeper.period` | Time unit | Defines the initial delay period before a background sweep is executed. |
|