Parquet writer from dataframe

parquetfier.py

import pandas as pd
import numpy as np
import pymssql

conn = pymssql.connect("localhost", "SA", "yourStrong(!)Password", "FORCE_PAPPA")

with open("task.sql") as infile:
  doc_query = infile.read().strip()

time_range = list(pd.date_range(start='2019-01-01', periods=12, freq="MS").strftime("%Y-%m-%d").values)
for k,v in enumerate(time_range):
  if k == len(time_range) - 1: break
  query = doc_query.format(time_range[k], time_range[k+1])
  df = pd.read_sql(query, conn)  
  if df.shape[0] > 0: df.to_parquet("task_{}.parquet".format(k))