延迟一小时入库

-1 hour -> start_time 相当于即时入库
-2 hour -> start_time -1 -> end_time 相当于延迟一小时入库

cucyuqing/cmd/es-sync.py

@@ -180,11 +180,11 @@ async def sync():
             await cur.execute(
                 """
             WITH RECURSIVE time_slots AS (
-                SELECT date_trunc('hour', now() - interval '1 hour') - interval '14 day' AS start_time
+                SELECT date_trunc('hour', now() - interval '2 hour') - interval '14 day' AS start_time
                 UNION ALL
                 SELECT start_time + INTERVAL '1 hour'
                 FROM time_slots
-                WHERE start_time < date_trunc('hour', now() - interval '1 hour')
+                WHERE start_time < date_trunc('hour', now() - interval '2 hour')
             )
             SELECT
                 ts.start_time,