Skip to content
Snippets Groups Projects
Commit d3579829 authored by IDreDD's avatar IDreDD
Browse files

Merge remote-tracking branch 'origin/master'

# Conflicts:
#	app.py
parents c2d1250a 97842ff2
No related branches found
No related tags found
No related merge requests found
......@@ -3,4 +3,4 @@ import os
os.system("apt-get update && apt-get upgrade")
os.system("apt-get install default-jdk")
os.system("spark-submit --master yarn routine_pull")
os.system("spark-submit --master yarn routine_pull.py")
......@@ -4,8 +4,6 @@ import sys
import requests
from requests.exceptions import HTTPError
import mysql.connector
import pyconf as cfg
from cern.nxcals.pyquery.builders import *
from pyspark import SparkConf
......@@ -24,14 +22,7 @@ API_HOST = 'http://test-nxdblm-api2.web.cern.ch/'
_dest_dir = './pulledData'
# mysqlDB variables
mydb = mysql.connector.connect(
host=cfg.mysql['host'],
port=cfg.mysql['port'],
user=cfg.mysql['user'],
passwd=cfg.mysql['passwd'],
database=cfg.mysql['database']
)
# Sparks Variable
conf = SparkConf()
......
pyspark
pyspark-stubs
requests
pytimber
pyconf
mysql-connector-python
\ No newline at end of file
pytimber
\ No newline at end of file
import time
import mysql.connector
import requests
from property_pull import property_pull
......@@ -10,15 +9,8 @@ import datetime as dt
# from multiprocessing import Process
# mysqlDB variables
import pyconf as cfg
mydb = mysql.connector.connect(
host=cfg.mysql['host'],
port=cfg.mysql['port'],
user=cfg.mysql['user'],
passwd=cfg.mysql['passwd'],
database=cfg.mysql['database']
)
API_HOST = 'http://test-nxdblm-api2.web.cern.ch/'
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment