Fetch data from MySQL and push it in Cassandra using spark in local mode and vice-versa. Using pyspark to featch data from MySQL and store into Elasticsearch.
-
Install MySQL.
-
Install elasticsearch in local system and check port is running or not.
-
Install spark in local system.
-
Clone the Repo.
git clone https://github.com/shivamgupta7/MySQL-To-NoSQL.git -
Go into the file and install all requirements.
cd MySQL-To-NoSQLpip install -r requirements.txt -
Edit
mysqlToEs.pyto give your host,database,userName,passwd,tableName,elsticHost,port,indexName. -
Run
mysqlToEs.pyfilepython mysqlToEs.py
-
Install MySQL.
-
Install Cassandra
-
Install spark in local system.
-
Clone the Repo.
git clone https://github.com/shivamgupta7/MySQL-To-NoSQL.git -
Go into the file and install all requirements.
cd MySQL-To-NoSQLpip install -r requirements.txt -
Edit
mysqlCassandr.pyto give your host,database,userName,passwd,tableName,keyspaceName,tableName. -
Run
mysqlCassandr.pyfilepython mysqlCassandra.py