美股开盘时间对照北京时间：几点开盘几点收盘

SELECT
    beijing_time,
    et_time,
    round(sum(volume) / 1e6, 2)       AS volume_millions,
    round(sum(transactions) / 1e3, 1) AS trades_thousands
FROM
(
    SELECT
        formatDateTime(toStartOfInterval(toTimeZone(window_start, 'Asia/Shanghai'), INTERVAL 30 MINUTE), '%H:%i')    AS beijing_time,
        formatDateTime(toStartOfInterval(toTimeZone(window_start, 'America/New_York'), INTERVAL 30 MINUTE), '%H:%i') AS et_time,
        toHour(toTimeZone(window_start, 'America/New_York')) * 60
            + intDiv(toMinute(toTimeZone(window_start, 'America/New_York')), 30) * 30                                AS et_minute_of_day,
        volume,
        transactions
    FROM global_markets.delayed_stocks_minute_aggs
    WHERE ticker = 'SPY'
      AND window_start >= toDateTime('2026-09-14 08:00:00', 'UTC')
      AND window_start <  toDateTime('2026-09-19 00:00:00', 'UTC')
)
GROUP BY beijing_time, et_time, et_minute_of_day
ORDER BY et_minute_of_day

SELECT
    toString(toStartOfMonth(session_date))                                              AS month,
    concat(toString(toYear(session_date)), '年', toString(toMonth(session_date)), '月')  AS month_label,
    round(avg(offset_hours), 2)                                                         AS beijing_minus_ny_hours,
    min(tape_start_bj)                                                                  AS earliest_tape_start_bj,
    max(tape_start_bj)                                                                  AS latest_tape_start_bj
FROM
(
    SELECT
        toDate(toTimeZone(window_start, 'America/New_York'))                     AS session_date,
        formatDateTime(toTimeZone(min(window_start), 'Asia/Shanghai'), '%H:%i')  AS tape_start_bj,
        (toHour(toTimeZone(min(window_start), 'Asia/Shanghai'))
         - toHour(toTimeZone(min(window_start), 'America/New_York')) + 24) % 24  AS offset_hours
    FROM global_markets.delayed_stocks_minute_aggs
    WHERE ticker = 'SPY'
      AND window_start >= today() - 400
      AND window_start <  today() - 2
    GROUP BY session_date
)
GROUP BY month, month_label
ORDER BY month

SELECT
    symbol,
    round(100 * sumIf(volume, et_minute <  570) / sum(volume), 2)                   AS premarket_pct,
    round(100 * sumIf(volume, et_minute >  960) / sum(volume), 2)                   AS afterhours_pct,
    round(100 * sumIf(volume, et_minute < 570 OR et_minute > 960) / sum(volume), 2) AS extended_pct
FROM
(
    SELECT
        ticker AS symbol,
        toHour(toTimeZone(window_start, 'America/New_York')) * 60
            + toMinute(toTimeZone(window_start, 'America/New_York')) AS et_minute,
        volume
    FROM global_markets.delayed_stocks_minute_aggs
    WHERE ticker IN ('SPY', 'AAPL', 'MSFT', 'NVDA', 'TSLA', 'KO')
      AND window_start >= toDateTime('2026-09-14 08:00:00', 'UTC')
      AND window_start <  toDateTime('2026-09-19 00:00:00', 'UTC')
)
GROUP BY symbol
ORDER BY extended_pct DESC

SELECT
    toString(date)                                                                    AS holiday_date,
    concat(toString(toMonth(date)), '月', toString(toDayOfMonth(date)), '日')          AS date_label,
    arrayElement(['周一', '周二', '周三', '周四', '周五', '周六', '周日'], toDayOfWeek(date)) AS weekday_cn,
    any(name)                                                                         AS holiday,
    any(status)                                                                       AS day_status,
    any(if(status = 'early-close',
           concat('次日 ', formatDateTime(toTimeZone(close, 'Asia/Shanghai'), '%H:%i')),
           ''))                                                                       AS beijing_close,
    dateDiff('day', today(), date)                                                    AS days_away
FROM global_markets.stocks_market_holidays
WHERE date >= today()
GROUP BY date
ORDER BY date