ga_s3_location = 's3://prod-fra-log-union-store/service-access-ad/%s/%s/%s/%s/%s/' awsRegion='eu-central-1' regins = ['xx','xxx','xxxx'] regins_glue_job_bucket_dic = {'fra':'prod-fra-glue-job','sgp':'prod-sgp-glue-job','sp':'prod-sp-glue-job-new'} redshift_database="fra_prod_redshift_basic" redshift_table_name="prod_basic_raw_access_ad" table_name = "raw_access_ad" ok_file_path = "job/finish_flag/%s/dt=%s/hour=%s/ok" arg_params=GlueJobParamas().smart_params() exec_ymd = arg_params['date_dict'].get('exec_ymd',None)#所有传入指定规则的时间参数全部被存入返回字典下的date_dict hour = arg_params['date_dict'].get('hour',None)#所有传入指定规则的时间参数全部被存入返回字典下的date_dict print(f"传入的时间参数 exec_ymd为【{exec_ymd}】,hour为【{hour}】") tz = pytz.timezone('Asia/Shanghai') # 东八区 last_day_time = (datetime.datetime.fromtimestamp(int(time.time()), tz)+ datetime.timedelta(hours=-1)) last_day_year = str(last_day_time.strftime('%Y')) last_day_month = str(last_day_time.strftime('%m')) last_day_day = str(last_day_time.strftime('%d')) last_day_hour = str(last_day_time.strftime('%H')) def is_valid_date(str): try: time.strptime(str, "%Y%m%d") return True except: return False def is_valid_hour(input_job_hour): if input_job_hour is not None: '''判断是否是一个有效的小时''' try: if int(input_job_hour) >= 0 and int(input_job_hour)<=23: return True except: return False else: return False

这段代码是一些变量和函数的定义，包括S3存储桶的地址、Glue Job的参数、Redshift数据库和表名、以及一些时间相关的函数和变量。其中有一个判断日期格式是否正确的函数is_valid_date和一个判断小时是否在0-23之间的函数is_valid_hour。这些变量和函数可能会在代码的其他部分被调用和使用。