*Aparece o seguinte erro: * wrapper = lambda x: [fn(x)] File "main.py", line 69, in chave_uf_ano_mes_de_lista data,mm,uf = elemento ValueError: not enough values to unpack (expected 3, got 1) [while running 'Criando uma chave UF-Ano-mes']
def chave_uf_ano_mes_de_lista(elemento): """ Receber uma lista de elementos Retornar uma tupla contando uma chave e o valor de uma chuva em mm ('UF-ANO-MES',1.3) """
data,mm,uf = elemento
ano_mes = "-".join(data.split("-")[:2])
chave = f"{uf}-{ano_mes}"
if float(mm) < 0:
mm = 0.0
else:
mm = float(mm)
return chave,mm
chuvas = (
pipeline
|"Leitura do dataset de chuvas" >> ReadFromText("chuvas.csv",skip_header_lines=1)
|"De texto para lista (chuvas)" >> beam.Map(texto_para_lista,delimitador = ',')
|"Criando uma chave UF-Ano-mes" >> beam.Map(chave_uf_ano_mes_de_lista)
|"Soma do total de chuvas pela chave" >> beam.CombinePerKey(sum)
# |"Arrendondar resultados de chuvas" >> beam.Map(arredonda)
|"Mostrar resultados de chuvas" >> beam.Map(print))