from cognite.client.data_classes.hosted_extractors import EventHubSourceWrite
job_write = EventHubSourceWrite('my_event_hub', 'http://myeventhub.com', "My EventHub", 'my_key', 'my_value')
job = client.hosted_extractors.jobs.create(job_write)

{
  "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
    }
  ]
}