Skip to content

A
airflow-dags-hub
Commit e2ede543 authored by 吴升宇's avatar 吴升宇
Browse files
Options

remove 注释

parent 2cf07028
Hide whitespace changes
Inline Side-by-side
Showing with 0 additions and 6 deletions
dags/psql/create_table_per_day.py
View file @ e2ede543
...@@ -24,18 +24,12 @@ dag = DAG( ...@@ -24,18 +24,12 @@ dag = DAG(
schedule_interval='0 0 1 * * 0', # 每月一号零点执行一次 schedule_interval='0 0 1 * * 0', # 每月一号零点执行一次
) )
# 获取当前日期
now_time = datetime.now() now_time = datetime.now()
# 获取当前时间的星期数和月数
week, days_num = calendar.monthrange(now_time.year, now_time.month) week, days_num = calendar.monthrange(now_time.year, now_time.month)
# 获取本月的最后一天
end_day_in_mouth = now_time.replace(day=days_num) end_day_in_mouth = now_time.replace(day=days_num)
# 获取下月的第一天
start_day = end_day_in_mouth + timedelta(days=1) start_day = end_day_in_mouth + timedelta(days=1)
month = start_day.strftime('y%Ym%m') month = start_day.strftime('y%Ym%m')
# 获取下月的星期数和月数
week, days_num = calendar.monthrange(start_day.year, start_day.month) week, days_num = calendar.monthrange(start_day.year, start_day.month)
# 获取下个月的最后一天
end_day = start_day + timedelta(days=(days_num-1)) end_day = start_day + timedelta(days=(days_num-1))
end_str = str(end_day.date()) end_str = str(end_day.date())
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment