heimoshuiyu/cucyuqing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix: es_intervals 为空

Browse Source
This commit is contained in:
黑墨水鱼
2024-09-14 12:00:10 +08:00
parent 2d5eae2a18
commit 615d96c663
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
cucyuqing/cmd/es-sync.py
View File

@@ -172,7 +172,7 @@ async def sync():
await cur.execute( await cur.execute(
""" """
WITH RECURSIVE time_slots AS ( WITH RECURSIVE time_slots AS (
SELECT date_trunc('hour', now() - interval '1 hour') - interval '1 day' AS start_time SELECT date_trunc('hour', now() - interval '1 hour') - interval '14 day' AS start_time
UNION ALL UNION ALL
SELECT start_time + INTERVAL '1 hour' SELECT start_time + INTERVAL '1 hour'
FROM time_slots FROM time_slots
@@ -193,6 +193,10 @@ async def sync():
ESInterval(start_time=row[0], end_time=row[1]) async for row in cur ESInterval(start_time=row[0], end_time=row[1]) async for row in cur
] ]
if not es_intervals:
print("没有待同步时间段，等待下一轮同步")
break
print( print(
f"开始同步 ES 数据，总共 {len(es_intervals)} 个时间段，从 {es_intervals[0].start_time} 到 {es_intervals[-1].end_time}" f"开始同步 ES 数据，总共 {len(es_intervals)} 个时间段，从 {es_intervals[0].start_time} 到 {es_intervals[-1].end_time}"
) )