diff --git a/camera/depthai.py b/camera/depthai.py index 76962e6..2e60965 100644 --- a/camera/depthai.py +++ b/camera/depthai.py @@ -1,8 +1,8 @@ +import datetime import logging import paho.mqtt.client as mqtt import events.events_pb2 -from google.protobuf.timestamp_pb2 import Timestamp import depthai as dai import cv2 @@ -63,11 +63,11 @@ class FramePublisher: is_success, im_buf_arr = cv2.imencode(".jpg", im_resize) byte_im = im_buf_arr.tobytes() - timestamp = Timestamp() + now = datetime.datetime.now() frame_msg = events.events_pb2.FrameMessage() frame_msg.id.name = "robocar-oak-camera-oak" - frame_msg.id.id = str(timestamp.ToMilliseconds()) - frame_msg.id.created_at.FromMilliseconds(timestamp.ToMilliseconds()) + frame_msg.id.id = str(int(now.timestamp() * 1000)) + frame_msg.id.created_at.FromDatetime(now) frame_msg.frame = byte_im logger.debug("publish frame event to %s", self._frame_topic)