pyspark

사이드 프로젝트[001]. SPARK와 MongoDB 연결(with pyspark)

1. 실습환경 : ubuntu20.04[Virtual Box] 2. 파일경로 : /usr/spark/pyspark-mongodb-connector.py 3. 작성코드 ##Spark 연결 테스트 코드### from pyspark.sql import SparkSession # 관리자명:비밀번호@아이피주소:포트/데이터베이스.collection?authSource=admin input_uri = "mongodb://hyeongju:dbgudwn1!@127.0.0.1:27017/mydatabase.testcol?authSource=admin" output_uri = "mongodb://hyeongju:dbgudwn1!@127.0.0.1:27017/mydatabase.testcol?authSource=admin" ..