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

{
  "items": [
    {
      "type": "mqtt3",
      "externalId": "my.known.id",
      "host": "<string>",
      "createdTime": 1730204346000,
      "lastUpdatedTime": 1730204346000,
      "port": 1883,
      "authentication": {
        "type": "basic",
        "username": "<string>"
      },
      "useTls": true,
      "caCertificate": {
        "thumbprint": "<string>",
        "expiresAt": 123
      },
      "authCertificate": {
        "thumbprint": "<string>",
        "expiresAt": 123
      }
    }
  ]
}