传多个参数（pyspark脚本）_pyspark sql传入参数

作者：Gausst松鼠会 | 2024-02-07 16:52:08

踩

pyspark sql传入参数

#############################################################################################
from pyspark.sql import SparkSession
import datetime
spark=SparkSession.builder.appName(“w9010794”).getOrCreate()

def gethql(dayno,dayno1) :
hql=f"""

   """
1

print(hql)
spark.sql(hql)
return

if name==“main” ：
start = datetime.datetime.strptime(“19-03-2021”,"%d-%m-%Y")
end = datetime.datetime.strptime(“19-08-2021”,"%d-%m-%Y")
start1 = datetime.datetime.strptime(“20-03-2021”,"%d-%m-%Y")
end1 = datetime.datetime.strptime(“20-08-2021”,"%d-%m-%Y")
ran = [start + datetime.timedelta(days=x) for x in range(0,(end-start).days)]
ran1 = [start1 + datetime.timedelta(days=x) for x in range(0,(end1-start1).days)]
for dail,daily in zip(ran,ran1) :
dail1 = dail.strftime("%Y%m%d")
dail2 = daily.strftime("%Y%m%d")
gethql=(dayno=dail1,dayno1=dail2)
##############################################################################################

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Gausst松鼠会/article/detail/66469