如何将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）。

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)