No meu código os arquivos subiram para o bucket porém foram sem dados. Será que houve algum problema com a biblioteca io? Conferi o código e não encontrei erros com o da transcrição.
Solucionado
No meu código os arquivos subiram para o bucket porém foram sem dados. Será que houve algum problema com a biblioteca io? Conferi o código e não encontrei erros com o da transcrição.
Olá Edson, tudo bem?
Notei uma inconsistência do seu código em relação ao da aula. Note que você está atribuindo ao df.to_parquet o parquet_buffer através do código df.to_parquet = parquet_buffer. Quando, na verdade, você deve passar a função parquet_buffer, como parâmetro em df.to_parquet
O código correto é:
from io import BytesIO
for ano, df in dfs.items():
parquet_buffer = BytesIO()
df.to_parquet(parquet_buffer)
s3.put_object(
Bucket="alura-datalakeaws",
Key=f"bronze/dados_{ano}.parquet",
Body=parquet_buffer.getvalue(),
)
Faça essa correção e verifique se o erro continua.
Espero ter ajudado.
Qualquer dúvida, compartilhe no fórum.
Abraços e bons estudos!