python - 如何将Kafka的时间戳转换为日期时间？

Question

下面显示了收到的消息。如何将时间戳转换为日期时间（python-kafka）？

ConsumerRecord(topic='topic', partition=0, offset=347, timestamp=1602086275744, timestamp_type=0, key=None, value={......}, headers=[], checksum=3460280057, serialized_key_size= -1，serialized_value_size=471，serialized_header_size=-1)。

标签： pythonapache-kafka

Answer 1

尝试这个：

from datetime import datetime
datetime.fromtimestamp(1602086275744 / 1000)

输出：

datetime.datetime(2020, 10, 7, 17, 57, 55, 744000)

为了保持精度，试试这个：

ms = 1602086275744
datetime.utcfromtimestamp(ms//1000).replace(microsecond=ms%1000*1000)

输出：datetime.datetime(2020, 10, 7, 15, 57, 55, 744000)

如果您想减少微秒，请执行以下操作：

datetime.utcfromtimestamp(1602086275744 // 1000)
datetime.datetime(2020, 10, 7, 15, 57, 55)