1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

#[macro_use]
extern crate log;
#[macro_use]
extern crate rlink_derive;

pub mod clickhouse_sink;

use chrono::{DateTime, NaiveDateTime, TimeZone};
use chrono_tz::Asia;

pub type DateTimeShanghai = DateTime<chrono_tz::Tz>;
/// timestamp to DateTime<Tz>
/// 1. Asia::Shanghai.ymd(2020, 11, 11).and_hms(12, 0, 1);
/// 2. let naive_dt = NaiveDateTime::from_timestamp(1604995711, 0);
//     let dt: DateTime<chrono_tz::Tz> = Asia::Shanghai.from_utc_datetime(&naive_dt);
pub fn timestamp_to_tz(ts: u64) -> DateTimeShanghai {
    let d = std::time::Duration::from_millis(ts);

    let secs = d.as_secs();
    let nsecs = (ts - secs * 1000) as u32 * 1_000_000;
    let naive_dt = NaiveDateTime::from_timestamp(secs as i64, nsecs);
    let dt: DateTime<chrono_tz::Tz> = Asia::Shanghai.from_utc_datetime(&naive_dt);
    dt
}