#############################################################################################
from pyspark.sql import SparkSession
import datetime
spark=SparkSession.builder.appName(“w9010794”).getOrCreate()
def gethql(dayno,dayno1) :
hql=f"""
"""
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)
##############################################################################################
