From 40980241dd7c248339b34f1fb44250318b890f29 Mon Sep 17 00:00:00 2001 From: Cameron Seamons Date: Mon, 15 Dec 2025 01:07:48 -0700 Subject: [PATCH] Got Spark working locally --- Scripts/bronze_to_silver.py | 58 +++++++++++++++++++++++++++++++++++++ 1 file changed, 58 insertions(+) create mode 100644 Scripts/bronze_to_silver.py diff --git a/Scripts/bronze_to_silver.py b/Scripts/bronze_to_silver.py new file mode 100644 index 0000000..514b702 --- /dev/null +++ b/Scripts/bronze_to_silver.py @@ -0,0 +1,58 @@ +import os +from pyspark.sql import SparkSession +from dotenv import load_dotenv + +load_dotenv() + +# ---- WINDOWS FIX ---- +os.environ.setdefault("HADOOP_HOME", "C:\\hadoop") +os.environ.setdefault("hadoop.home.dir", "C:\\hadoop") +os.environ["PATH"] += ";C:\\hadoop\\bin" + + +spark = ( + SparkSession.builder + .appName("bronze-to-silver-batch") + + # ---- ALL JARS IN ONE PLACE ---- + .config( + "spark.jars.packages", + ",".join([ + # Delta + "io.delta:delta-core_2.12:2.3.0", + + # S3A + "org.apache.hadoop:hadoop-aws:3.3.4", + "com.amazonaws:aws-java-sdk-bundle:1.12.262" + ]) + ) + + # ---- DELTA ---- + .config("spark.sql.extensions", "io.delta.sql.DeltaSparkSessionExtension") + .config("spark.sql.catalog.spark_catalog", "org.apache.spark.sql.delta.catalog.DeltaCatalog") + + # ---- S3 ---- + .config("spark.hadoop.fs.s3a.endpoint", os.getenv("STORAGE_ENDPOINT")) + .config("spark.hadoop.fs.s3a.access.key", os.getenv("STORAGE_ACCESS_KEY")) + .config("spark.hadoop.fs.s3a.secret.key", os.getenv("STORAGE_SECRET_KEY")) + .config("spark.hadoop.fs.s3a.path.style.access", "true") + .config("spark.hadoop.fs.s3a.impl", "org.apache.hadoop.fs.s3a.S3AFileSystem") + + .getOrCreate() + +) + +print("Spark created OK") + + +# Prove S3A filesystem class is on the classpath +print("fs.s3a.impl =", spark.sparkContext._jsc.hadoopConfiguration().get("fs.s3a.impl")) + +# Force a real read/action from S3 +df = spark.read.json("s3a://camdoesdata/bronze/transactions_raw/") +print("About to show() ...") +df.limit(5).show(truncate=False) + +print("Done.") +spark.stop() +