我有一个模拟器python,它将数据发送到memsql,我试图在列中保存时间戳,但它给了我一个错误
Incorrect datetime value: '1530181024560' for column 'event_time' at row
这是我的python代码,我生成的事件时间格式如下:1530181024560
from datetime import datetime, timezone, timedelta
now = datetime.now(timezone.utc)
epoch = datetime(1970, 1, 1, tzinfo=timezone.utc) # use POSIX epoch
posix_timestamp_micros = (now - epoch) // timedelta(microseconds=1)
event_time = lambda:str(posix_timestamp_micros // 1000)
我尝试了datetime(3)和timestamp(3),但是没有办法。
1条答案
按热度按时间oxf4rvwz1#
我应用的解决方案是将时间戳保存为数据库中的bigint,然后当我在spark中提取数据时(对我来说是这样),我使用eventime.cast(timestamptype)将值转换为timestamp