Andrymahomby/data_Extraction
0
1import os2import sys3 4# On verrouille le chemin vers TON environnement virtuel5path_python = r'D:\M2\projet_interroperabilite\venv\Scripts\python.exe'6os.environ['PYSPARK_PYTHON'] = path_python7os.environ['PYSPARK_DRIVER_PYTHON'] = path_python8os.environ['HADOOP_HOME'] = r'C:\hadoop'9 10from pyspark.sql import SparkSession11 12spark = SparkSession.builder \13 .appName("TestFinal") \14 .master("local[*]") \15 .getOrCreate()16 17print("Vérification en cours...")18df = spark.createDataFrame([("Razafindrakoto", "M2 Success")], ["Nom", "Status"])19df.show()