Ola, fiz o código da pasta sript até o salvamento dos dados, seguindo as video aulas, segue o meu código:
import json
import csv
path_json='data_raw/dados_empresaA.json'
path_csv= 'data_raw/dados_empresaB.csv'
def leitura_json(path_json):
dados_json=[]
with open(path_json, 'r') as file:
dados_json= json.load(file)
return dados_json
def leitura_csv(path_csv):
dados_csv=[]
with open(path_csv, 'r') as file:
spamreader= csv.DictReader(file, delimiter=',')
for row in spamreader:
dados_csv.append(row)
return dados_csv
def leitura_dados(path, tipo_arquivo):
dados=[]
if tipo_arquivo=='json':
dados=leitura_json(path)
elif tipo_arquivo=='csv':
dados=leitura_csv(path)
return dados
def get_columns(dados):
return list(dados[-1].keys())
def rename_columns(dados, key_mapping):
new_dados_csv = []
for old_dict in dados:
dict_temp = {}
for old_key, value in old_dict.items():
dict_temp[key_mapping[old_key]] = value
new_dados_csv.append(dict_temp)
return new_dados_csv
def size_data(dados):
return len(dados)
def join(dadosA, dadosB):
combined_list = []
combined_list.extend(dadosA)
combined_list.extend(dadosB)
return combined_list
def transformando_dados_tabela(dados, nomes_colunas):
dados_combinados_tabela = [nomes_colunas]
for row in dados:
linha = []
for coluna in nomes_colunas:
linha.append(row.get(coluna, 'Indisponivel'))
dados_combinados_tabela.append(linha)
return dados_combinados_tabela
def salvando_dados(dados, path):
with open(path, 'w') as file:
writer = csv.writer(file)
writer.writerows(dados)
#Iniciando a leitura
dados_json=leitura_dados(path_json, 'json')
dados_csv=leitura_dados(path_csv,'csv')
nome_colunas_json=get_columns(dados_json)
tamanho_dados_csv=size_data(dados_csv)
key_mapping = {'Nome do Item': 'Nome do Produto',
'Classificação do Produto': 'Categoria do Produto',
'Valor em Reais (R$)': 'Preço do Produto (R$)',
'Quantidade em Estoque': 'Quantidade em Estoque',
'Nome da Loja': 'Filial',
'Data da Venda': 'Data da Venda'}
dados_csv=rename_columns(dados_csv, key_mapping)
nome_colunas_csv=get_columns(dados_csv)
print(nome_colunas_csv)
dados_fusao=join(dados_csv,dados_json)
nome_colunas_fusao=get_columns(dados_fusao)
tamanho_dados_fusao=size_data(dados_fusao)
# Salvando dados
dados_fusao_tabela = transformando_dados_tabela(dados_fusao, nome_colunas_fusao)
path_dados_combinados = 'data_processed/dados_combinados.csv'
salvando_dados(dados_fusao_tabela, path_dados_combinados)
print(path_dados_combinados)
Porém hoje quando dei um play no terminal apareceu o seguinte erro
Não sei o que pode ser pois fiz da mesma forma que o instrutor