Мой метод
def myfunc(filename, filepath):
result_df = pd.DataFrame()
with open(filename, encoding='utf-8', mode='r') as i:
data = pd.read_json(i, lines=True)
result_df.append(data)
table_from_pandas = pa.Table.from_pandas(result_df)
pq.write_table(table_from_pandas,filepath)
return result_df
Pycharm показывает
(<class 'NameError'>, NameError("name 'result_df' is not defined"), <traceback object at 0x1135a0500>)
Из оболочки Python все работает нормально. Но мне нужно как-то заранее определить мой df, чтобы использовать мой метод. Это мой код:
if __name__ == '__main__':
files = os.listdir('/Users/milenko/mario/Json_gzips')
files = [fi for fi in files if fi.endswith(".gz")]
my_dict = {'ticr_calculated_2': 'ticr-2.parquet', 'ticr_calculated_3': 'ticr-3.parquet', \
'ticr_calculated_4': 'ticr-4.parquet', 'tick_calculated_2': 'tick-2.parquet', \
'tick_calculated_3': 'tick-3.parquet', 'tick_calculated_4': 'tick-4.parquet'}
basic = '/Users/milenko/mario/Json_gzips/'
json_fi = glob.glob("*.json")
for key, value in my_dict.items():
for f in json_fi:
if re.match(key, f):
filepath = basic + value
myfunc(f, filepath)
Как это решить?