在Python源文件的最开始一行，加入一句：

coding=UTF-8（等号换为”:“也可以）

或者

-- coding:UTF-8 --

hive sql中参数是取自py，两层
CREATE TABLE if not EXISTS {{params.ads}}.{{params.ads_ci_persontriprel}}(
imsi string,
tripid string,
stime int,
etime int)
ROW FORMAT SERDE
‘org.apache.hadoop.hive.ql.io.orc.OrcSerde’
STORED AS INPUTFORMAT
‘org.apache.hadoop.hive.ql.io.orc.OrcInputFormat’
OUTPUTFORMAT
‘org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat’;

node_ads_active_regional_step_2 = SSHOperator(
task_id = ‘ads_active_regional_step_2’,
command = “script_ads_active_regional_step_2.sh”,
ssh_conn_id=’ssh-sh’,
params = {
‘dwd’: dwd,
‘dwd_imsi_removeduplicate’: dwd_imsi_removeduplicate,
‘ads’: ads,
‘ads_imsicar_tag’: ads_imsicar_tag,
‘now_day’: now_day,
‘ads_active_regional’: ads_active_regional
},
dag = dag)