from cognite.client.data_classes.hosted_extractors import EventHubSourceUpdate
job = EventHubSourceUpdate('my_event_hub').event_hub_name.set("My Updated EventHub")
updated_job = client.hosted_extractors.jobs.update(job){
"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
}
]
}Required capabilities:
hostedExtractors:WRITE
Update a list of up to 100 jobs.
from cognite.client.data_classes.hosted_extractors import EventHubSourceUpdate
job = EventHubSourceUpdate('my_event_hub').event_hub_name.set("My Updated EventHub")
updated_job = client.hosted_extractors.jobs.update(job){
"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
}
]
}Access token issued by the CDF project's configured identity provider. Access token must be an OpenID Connect token, and the project must be configured to accept OpenID Connect tokens. Use a header key of 'Authorization' with a value of 'Bearer $accesstoken'. The token can be obtained through any flow supported by the identity provider.
Jobs to update.
Show child attributes
List of updated jobs.
Show child attributes
Was this page helpful?