A hosted extractor job represents the running extractor. Jobs produce logs and metrics that give the state of the job. For details on available states and metrics see documentation here.
Required capabilities:
hostedExtractors:READ
List all jobs in a given project. If more than limit jobs exist, a cursor for pagination will be returned with the response.
List of jobs and an optional cursor.
The response for a bad request.
Validation Error
job_list = client.hosted_extractors.jobs.list(limit=5) for job in client.hosted_extractors.jobs: job # do something with the job for job_list in client.hosted_extractors.jobs(chunk_size=25): job_list # do something with the jobs
{- "items": [
- {
- "externalId": "my.known.id",
- "destinationId": "string",
- "sourceId": "string",
- "format": {
- "type": "rockwell",
- "encoding": "utf8",
- "compression": "gzip",
- "prefix": {
- "fromTopic": true,
- "prefix": "string"
}, - "dataModels": {
- "space": "string"
}
}, - "targetStatus": "running",
- "status": "startup_error",
- "config": {
- "topicFilter": "string"
}, - "createdTime": 1730204346000,
- "lastUpdatedTime": 1730204346000,
- "name": "string",
- "description": "string",
- "metadata": {
- "property1": "string",
- "property2": "string"
}
}
], - "nextCursor": "string"
}Required capabilities:
hostedExtractors:READhostedExtractors:WRITE
Create up to 10 jobs.
Jobs to create.
required | Array of objects (Items) [ 1 .. 10 ] items |
Successful Response
The response for a bad request.
Validation Error
{- "items": [
- {
- "externalId": "my.known.id",
- "destinationId": "string",
- "sourceId": "string",
- "format": {
- "type": "rockwell",
- "encoding": "utf8",
- "compression": "gzip",
- "prefix": {
- "fromTopic": true,
- "prefix": "string"
}, - "dataModels": {
- "space": "string"
}
}, - "config": {
- "topicFilter": "string"
}, - "name": "string",
- "description": "string",
- "metadata": {
- "property1": "string",
- "property2": "string"
}
}
]
}{- "items": [
- {
- "externalId": "my.known.id",
- "destinationId": "string",
- "sourceId": "string",
- "format": {
- "type": "rockwell",
- "encoding": "utf8",
- "compression": "gzip",
- "prefix": {
- "fromTopic": true,
- "prefix": "string"
}, - "dataModels": {
- "space": "string"
}
}, - "targetStatus": "running",
- "status": "startup_error",
- "config": {
- "topicFilter": "string"
}, - "createdTime": 1730204346000,
- "lastUpdatedTime": 1730204346000,
- "name": "string",
- "description": "string",
- "metadata": {
- "property1": "string",
- "property2": "string"
}
}
]
}Required capabilities:
hostedExtractors:READ
Retrieve a list of up to 100 jobs by their external ID, optionally ignoring unknown IDs.
List of retrieved jobs.
The response for a bad request.
Validation Error
{- "items": [
- {
- "externalId": "my.known.id"
}
], - "ignoreUnknownIds": true
}{- "items": [
- {
- "externalId": "my.known.id",
- "destinationId": "string",
- "sourceId": "string",
- "format": {
- "type": "rockwell",
- "encoding": "utf8",
- "compression": "gzip",
- "prefix": {
- "fromTopic": true,
- "prefix": "string"
}, - "dataModels": {
- "space": "string"
}
}, - "targetStatus": "running",
- "status": "startup_error",
- "config": {
- "topicFilter": "string"
}, - "createdTime": 1730204346000,
- "lastUpdatedTime": 1730204346000,
- "name": "string",
- "description": "string",
- "metadata": {
- "property1": "string",
- "property2": "string"
}
}
]
}Required capabilities:
hostedExtractors:WRITE
Delete a list of jobs by their external ID.
Empty response
The response for a bad request.
Validation Error
{- "items": [
- {
- "externalId": "my.known.id"
}
], - "ignoreUnknownIds": true
}{ }Required capabilities:
hostedExtractors:READ
List logs, optionally filtering on job, source, or destination. Logs are retrieved in reverse chronological order.
List of retrieved job logs
The response for a bad request.
Validation Error
res = client.hosted_extractors.jobs.list_logs(job="myJob")
{- "items": [
- {
- "jobExternalId": "string",
- "type": "paused",
- "message": "string",
- "createdTime": 1730204346000
}
]
}Required capabilities:
hostedExtractors:READ
List metrics, optionally filtering on job, source, or destination. Logs are retrieved in reverse chronological order.
List of retrieved job metrics.
The response for a bad request.
Validation Error
res = client.hosted_extractors.jobs.list_metrics(job="myJob")
{- "items": [
- {
- "jobExternalId": "string",
- "timestamp": 0,
- "sourceMessages": 0,
- "sourceBytes": 0,
- "cdfInputValues": 0,
- "cdfRequests": 0,
- "transformFailures": 0,
- "cdfWriteFailures": 0,
- "cdfSkippedValues": 0,
- "cdfFailedValues": 0,
- "cdfUploadedValues": 0
}
]
}Required capabilities:
hostedExtractors:WRITE
Update a list of up to 100 jobs.
Jobs to update.
required | Array of objects (Items) [ 1 .. 10 ] characters |
List of updated jobs.
The response for a bad request.
Validation Error
{- "items": [
- {
- "externalId": "my.known.id",
- "update": {
- "destinationId": {
- "set": "string"
}, - "format": {
- "set": {
- "type": "rockwell",
- "encoding": "utf8",
- "compression": "gzip",
- "prefix": {
- "fromTopic": true,
- "prefix": "string"
}, - "dataModels": {
- "space": "string"
}
}
}, - "sourceId": {
- "set": "string"
}, - "targetStatus": {
- "set": "running"
}, - "config": {
- "set": {
- "topicFilter": "string"
}
}, - "name": {
- "set": "string"
}, - "description": {
- "set": "string"
}, - "metadata": {
- "set": {
- "property1": "string",
- "property2": "string"
}
}
}
}
]
}{- "items": [
- {
- "externalId": "my.known.id",
- "destinationId": "string",
- "sourceId": "string",
- "format": {
- "type": "rockwell",
- "encoding": "utf8",
- "compression": "gzip",
- "prefix": {
- "fromTopic": true,
- "prefix": "string"
}, - "dataModels": {
- "space": "string"
}
}, - "targetStatus": "running",
- "status": "startup_error",
- "config": {
- "topicFilter": "string"
}, - "createdTime": 1730204346000,
- "lastUpdatedTime": 1730204346000,
- "name": "string",
- "description": "string",
- "metadata": {
- "property1": "string",
- "property2": "string"
}
}
]
}