Skip to content
Snippets Groups Projects
Commit 1900930b authored by lcd22's avatar lcd22
Browse files

fix nome do diretório bronze

parent d71461a1
Branches
No related tags found
No related merge requests found
...@@ -125,7 +125,7 @@ schema = StructType([ ...@@ -125,7 +125,7 @@ schema = StructType([
print("Esquema definido com sucesso.") print("Esquema definido com sucesso.")
# Carregar JSON com o esquema # Carregar JSON com o esquema
input_path = "s3a://landing/warehouse/fichas_cadastro_individual_200000.json" input_path = "s3a://landing/warehouse/fichas_cadastro_individual_200000.json"
output_path = "s3a://bronze/warehouse/fichas_cadastro_individual_200000_parquet" output_path = "s3a://bronze/warehouse/fichas_cadastro_individual"
try: try:
print("Carregando dados do JSON...") print("Carregando dados do JSON...")
df = spark.read.schema(schema).json(input_path) df = spark.read.schema(schema).json(input_path)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment