我无法使用python而不是pyspark将数据从数据库写入blob存储。
我没有收到任何错误消息
indices = ['COUNTRY', 'COUNTRYNUMBER', 'COUNTRYREPORTINGSITENAME']
bound_start = date.today() - pd.offsets.Week(offset, weekday=6)
bound_end = bound_start + timedelta(days=days)
data = query_snowflake()
result = old_model(data, bound_start, bound_end)
print(result)
result.to_csv(r'/dbfs/mnt/storageaccountname/forecastdata/filename.csv')
result['ID'] = result.index.map(str) + ',' + result['NUMBER'].map(str)
return result.set_index(indices, append=True).reorder_levels([1, 2, 3, 0])
1条答案
按热度按时间3b6akqbq1#
给定的代码应按预期工作。请检查路径是否包含任何使用
os.listdir的文件。还请尝试从同一路径阅读，以检查数据是否已写入或是否出现错误。