2016-04-25 8 views
6

का उपयोग कर MySQL डेटाबेस तालिका से पढ़ा गया है मेरे पास MySQL में 'उपयोगकर्ता' तालिका है। मैं इसे अपने स्पार्क एसक्यूएल प्रोग्राम में पढ़ना चाहता हूं। मैं Python का उपयोग कर अप्स स्पार्क के स्पार्कएसक्यूएल मॉड्यूल में MySQL से तालिका को कैसे पढ़ सकता हूं? क्या इस कनेक्टर के लिए मैं एक कनेक्टर का उपयोग कर सकता हूं? धन्यवाद।स्पार्कएसक्यूएल पाइथन

उत्तर

6

similar question answered है। इस

./bin/pyspark --packages mysql:mysql-connector-java:5.1.38 

तरह pyspark शुरू तो बस

sqlContext.read.format("jdbc").options(
url ="jdbc:mysql://localhost/mysql", 
driver="com.mysql.jdbc.Driver", 
dbtable="user", 
user="root", 
password="" 
).load().take(10) 

यह सबसे अधिक संभावना सिर्फ काम करेगा चलाते हैं। लेकिन यह आपके mysql सेट-अप पर निर्भर करता है, इसलिए यदि यह पासवर्ड, उपयोगकर्ता नाम, डीबी-यूआरएल और अन्य सेटिंग्स बदलने की कोशिश नहीं करता है।