IoT hub with kafka connector - how to decode the enqueued timestamp and device id
Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
06-18-2024 01:29 AM
I'm reading data from the default endpoint of an IoT hub in azure using the kafka connector in Databricks. Most data items are straight forward, but the device id and the timestamp I haven't been able to properly decode
For example, the key-value map of the headers {"key": "iothub-enqueuedtime", "value": "gwAAAZAMsGjg"} should be a recent timestamp. Any ideas on how to decode this, using pyspark?