You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

如何在ggplot2的geom_segment甘特图中将UTC转成EET时间?

问题描述

我正在尝试将UTC时间转换为EET时间,用于绘制展示Cron调度任务的甘特图,当前调度时间以UTC格式存储。请问如何调整时间转换逻辑,使图表的Y轴显示正确(例如AA任务的StartTime应显示为05:00而非03:00)?

原代码

library(jsonlite)
library(dplyr)
library(ggplot2)
library(scales)
library(lubridate)

# JSON data
json_data <- '[
{"SchedulingName": "AA", "cronExpr": "0 3 * * *"},
{"SchedulingName": "AB", "cronExpr": "30 2 * * *"},
{"SchedulingName": "AC", "cronExpr": "30 2 * * *"},
{"SchedulingName": "AD", "cronExpr": "0 6 * * *"},
{"SchedulingName": "ADD", "cronExpr": "30 2 * * *"},
{"SchedulingName": "ADER", "cronExpr": "55 1,7 * * *"},
{"SchedulingName": "ADF", "cronExpr": "9 9 * * *"},
{"SchedulingName": "ERE", "cronExpr": "0 0 * * 0"},
{"SchedulingName": "DFA", "cronExpr": "0 5 * * *"},
{"SchedulingName": "DFD", "cronExpr": "45 6 * * *"},
{"SchedulingName": "GREW", "cronExpr": "30 2 * * *"},
{"SchedulingName": "ASDFA", "cronExpr": "9 9 * * *"},
{"SchedulingName": "AFERE", "cronExpr": "30 4 * * *"},
{"SchedulingName": "DFAARE", "cronExpr": "30 2 * * *"},
{"SchedulingName": "DFARE", "cronExpr": "9 9 * * *"},
{"SchedulingName": "DAFAD", "cronExpr": "30 2 * * *"},
{"SchedulingName": "ADWER", "cronExpr": "0 5 * * *"},
{"SchedulingName": "OASDFAS", "cronExpr": "0 3 * * *"},
{"SchedulingName": "ASDPFAS", "cronExpr": "50 2 * * *"},
{"SchedulingName": "ASDFASDF", "cronExpr": "45 3 * * *"},
{"SchedulingName": "AERED", "cronExpr": "0 22 * * *"},
{"SchedulingName": "ASDFAER", "cronExpr": "30 5,12 * * *"},
{"SchedulingName": "AREWVSD", "cronExpr": "9 9 * * *"},
{"SchedulingName": "SARAER", "cronExpr": "30 2 * * *"},
{"SchedulingName": "QEFHF", "cronExpr": "0 3 * * *"},
{"SchedulingName": "AFEREADF", "cronExpr": "30 3 * * *"},
{"SchedulingName": "UTKY", "cronExpr": "30 6 * * *"},
{"SchedulingName": "IUOU", "cronExpr": "0 5 * * *"},
{"SchedulingName": "KYDF", "cronExpr": "0 7 * * *"},
{"SchedulingName": "DSARAE", "cronExpr": "0 0 * * *"},
{"SchedulingName": "KYRT", "cronExpr": "9 9 * * *"},
{"SchedulingName": "WERRYHN", "cronExpr": "0 1 * * *"},
{"SchedulingName": "FHSUR", "cronExpr": "30 12 * * *"},
{"SchedulingName": "PIU", "cronExpr": "30 23 * * *"},
{"SchedulingName": "ASDGYHBDV", "cronExpr": "0 3 * * *"},
{"SchedulingName": "KYIUY", "cronExpr": "0 19 * * *"},
{"SchedulingName": "IRETH", "cronExpr": "9 9 * * *"},
{"SchedulingName": "JTUT", "cronExpr": "31 23 * * *"},
{"SchedulingName": "HRURJU", "cronExpr": "0 20 * * *"}
]'

# Convert JSON to DataFrame
cron_jobs <- fromJSON(json_data)
head(cron_jobs)

# Process data to extract times and create POSIXct timestamps
cron_jobs <- cron_jobs %>%
  mutate(
    Minute = as.numeric(sub("^(\\d+)\\s.*", "\\1", cronExpr)),
    Hour = as.numeric(sub("^\\d+\\s(\\d+).*", "\\1", cronExpr)),
    StartTime = as.POSIXct(paste("2024-01-01", Hour, Minute), format = "%Y-%m-%d %H %M", tz = "UTC"),
    EndTime = StartTime + 720,  # Add 12 minutes for task duration
    StartTime = as_datetime(StartTime, tz = 'Europe/Helsinki'),
    EndTime = as_datetime(EndTime, tz = "Europe/Helsinki")
  )
head(cron_jobs)

# Sort the factor levels for better visualization
cron_jobs <- cron_jobs %>%
  arrange(SchedulingName) %>%
  mutate(SchedulingName = factor(SchedulingName, levels = rev(unique(SchedulingName))))

# Date range for the Gantt chart
full_day_start <- force_tz(as.POSIXct("2024-01-01 00:00", format = "%Y-%m-%d %H:%M", tz = "UTC"), tzone = "Europe/Helsinki")
full_day_end <- force_tz(as.POSIXct("2024-01-02 00:00", format = "%Y-%m-%d %H:%M", tz = "UTC"), tzone = "Europe/Helsinki")

# Create Gantt chart
ggplot(cron_jobs, aes(x = SchedulingName, y = StartTime, xend = SchedulingName, yend = EndTime)) +
  geom_segment(size = 3, color = "red") +
  coord_flip() +
  scale_y_datetime(
    breaks = seq(full_day_start, full_day_end, by = "1 hour"),
    labels = date_format("%H:%M"),
    limits = c(full_day_start, full_day_end)
  ) +
  labs(title = "Cron Schedule Gantt Chart (EET)", x = "Task", y = "Time") +
  theme_minimal() +
  theme(
    axis.text.x = element_text(angle = 90, hjust = 1)
  )

问题分析与解决方案

核心问题

  1. 时区转换逻辑错误:原代码用as_datetime(..., tz=...)仅修改了时间对象的时区属性,并未实际将UTC时间转换为EET时间,导致显示的时间仍为UTC值。
  2. 多小时Cron表达式处理缺失:部分任务的cron表达式包含多个小时(如ADER的55 1,7 * * *),原代码仅提取第一个小时值,导致任务只显示一次。

修改步骤

  1. 正确转换时区:使用with_tz()函数将UTC时间转换为EET时区,这是lubridate中专门用于时区转换的函数,会真正调整时间数值。
  2. 拆分多小时表达式:用separate_rows()拆分逗号分隔的小时字符串,生成多行数据,确保每个小时的任务都能在图表中显示。
  3. 简化时间范围定义:直接以EET时区创建全天的起始和结束时间,避免时区转换带来的混淆。

修改后的完整代码

library(jsonlite)
library(dplyr)
library(ggplot2)
library(scales)
library(lubridate)

# JSON data
json_data <- '[
{"SchedulingName": "AA", "cronExpr": "0 3 * * *"},
{"SchedulingName": "AB", "cronExpr": "30 2 * * *"},
{"SchedulingName": "AC", "cronExpr": "30 2 * * *"},
{"SchedulingName": "AD", "cronExpr": "0 6 * * *"},
{"SchedulingName": "ADD", "cronExpr": "30 2 * * *"},
{"SchedulingName": "ADER", "cronExpr": "55 1,7 * * *"},
{"SchedulingName": "ADF", "cronExpr": "9 9 * * *"},
{"SchedulingName": "ERE", "cronExpr": "0 0 * * 0"},
{"SchedulingName": "DFA", "cronExpr": "0 5 * * *"},
{"SchedulingName": "DFD", "cronExpr": "45 6 * * *"},
{"SchedulingName": "GREW", "cronExpr": "30 2 * * *"},
{"SchedulingName": "ASDFA", "cronExpr": "9 9 * * *"},
{"SchedulingName": "AFERE", "cronExpr": "30 4 * * *"},
{"SchedulingName": "DFAARE", "cronExpr": "30 2 * * *"},
{"SchedulingName": "DFARE", "cronExpr": "9 9 * * *"},
{"SchedulingName": "DAFAD", "cronExpr": "30 2 * * *"},
{"SchedulingName": "ADWER", "cronExpr": "0 5 * * *"},
{"SchedulingName": "OASDFAS", "cronExpr": "0 3 * * *"},
{"SchedulingName": "ASDPFAS", "cronExpr": "50 2 * * *"},
{"SchedulingName": "ASDFASDF", "cronExpr": "45 3 * * *"},
{"SchedulingName": "AERED", "cronExpr": "0 22 * * *"},
{"SchedulingName": "ASDFAER", "cronExpr": "30 5,12 * * *"},
{"SchedulingName": "AREWVSD", "cronExpr": "9 9 * * *"},
{"SchedulingName": "SARAER", "cronExpr": "30 2 * * *"},
{"SchedulingName": "QEFHF", "cronExpr": "0 3 * * *"},
{"SchedulingName": "AFEREADF", "cronExpr": "30 3 * * *"},
{"SchedulingName": "UTKY", "cronExpr": "30 6 * * *"},
{"SchedulingName": "IUOU", "cronExpr": "0 5 * * *"},
{"SchedulingName": "KYDF", "cronExpr": "0 7 * * *"},
{"SchedulingName": "DSARAE", "cronExpr": "0 0 * * *"},
{"SchedulingName": "KYRT", "cronExpr": "9 9 * * *"},
{"SchedulingName": "WERRYHN", "cronExpr": "0 1 * * *"},
{"SchedulingName": "FHSUR", "cronExpr": "30 12 * * *"},
{"SchedulingName": "PIU", "cronExpr": "30 23 * * *"},
{"SchedulingName": "ASDGYHBDV", "cronExpr": "0 3 * * *"},
{"SchedulingName": "KYIUY", "cronExpr": "0 19 * * *"},
{"SchedulingName": "IRETH", "cronExpr": "9 9 * * *"},
{"SchedulingName": "JTUT", "cronExpr": "31 23 * * *"},
{"SchedulingName": "HRURJU", "cronExpr": "0 20 * * *"}
]'

# Convert JSON to DataFrame
cron_jobs <- fromJSON(json_data)

# Process data: handle multi-hour cron expressions and convert time zones
cron_jobs <- cron_jobs %>%
  mutate(
    # 提取分钟和原始小时字符串(支持多小时)
    Minute = as.numeric(sub("^(\\d+)\\s.*", "\\1", cronExpr)),
    Hour_str = sub("^\\d+\\s(\\d+(?:,\\d+)*).*", "\\1", cronExpr)
  ) %>%
  # 拆分多小时表达式为单独行
  separate_rows(Hour_str, sep = ",") %>%
  mutate(
    Hour = as.numeric(Hour_str),
    # 创建UTC时间戳
    StartTime_UTC = as.POSIXct(paste("2024-01-01", Hour, Minute), format = "%Y-%m-%d %H %M", tz = "UTC"),
    EndTime_UTC = StartTime_UTC + 720,  # 任务持续12分钟
    # 转换为EET时区(Europe/Helsinki)
    StartTime = with_tz(StartTime_UTC, tz = "Europe/Helsinki"),
    EndTime = with_tz(EndTime_UTC, tz = "Europe/Helsinki")
  ) %>%
  # 移除临时辅助列
  select(-Hour_str, -StartTime_UTC, -EndTime_UTC)

# 排序任务名称,优化可视化顺序
cron_jobs <- cron_jobs %>%
  arrange(SchedulingName) %>%
  mutate(SchedulingName = factor(SchedulingName, levels = rev(unique(SchedulingName))))

# 定义EET时区的全天时间范围
full_day_start <- as.POSIXct("2024-01-01 00:00", format = "%Y-%m-%d %H:%M", tz = "Europe/Helsinki")
full_day_end <- as.POSIXct("2024-01-02 00:00", format = "%Y-%m-%d %H:%M", tz = "Europe/Helsinki")

# 绘制甘特图
ggplot(cron_jobs, aes(x = SchedulingName, y = StartTime, xend = SchedulingName, yend = EndTime)) +
  geom_segment(size = 3, color = "red") +
  coord_flip() +
  scale_y_datetime(
    breaks = seq(full_day_start, full_day_end, by = "1 hour"),
    labels = date_format("%H:%M"),
    limits = c(full_day_start, full_day_end)
  ) +
  labs(title = "Cron调度任务甘特图(EET时区)", x = "任务名称", y = "时间") +
  theme_minimal() +
  theme(
    axis.text.x = element_text(angle = 90, hjust = 1)
  )

效果说明

修改后,AA任务的UTC时间03:00会被正确转换为EET的05:00(EET比UTC快2小时),同时像ADER这样的多小时任务会在EET的03:00和09:00各显示一次,图表的Y轴时间完全符合EET时区的预期。

内容的提问来源于stack exchange,提问作者jrara

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.25 08:38:09