使用python链接mysql读入一个表并把它再写到hbase 里去（九头蛇万岁）

先声明一下需要用的库：

俩！！：

happybase    （写这个的老哥真的happy）

pymysql

建议使用anaconda进行相应版本匹配安装，在装happybase的时候，conda默认的channel是找不到这个库的你需要使用 conda-forge 镜像参考如下网站：

https://anaconda.org/conda-forge/happybase

pymysql就不用说了，毕竟mysql业界广泛使用，这个平台都好找

安装好了之后打开你的pycharm把基本purepython项目创建好，解释器指定到anaconda3下面的python.exe上面

然后开始玩耍：

Step1:

         请打算开你的大数据环境启动hadoop、zookeeper、hbase（简直后台内存爆掉）

Step2:

         开始编写自己的脚本，建议表级别操作和数据级别操作分别写脚本，这样会好控制一些。

这里我简单写了四个脚本

test.py,mysql.py,delete.py,scan.py

(test开始没规划，实际就是创表脚本)

test.py

[url=][/url]
1 #!/usr/bin/python 2 # coding:utf-8 3 import happybase 4  5 connection = happybase.Connection('localhost', 9090) 6  7 connection.create_table( 8     'short', 9     {10         'base':dict(),11         'region':dict(),12         'infos':dict()13     }14 )[url=][/url]

这里面很简单的操作，你要用hbase，你就要链接它，happybase.Connection(主机名, 端口号)参数就这么简单，对应好就ok

这里创建表的方法写法和hbase的操作感觉相当的像，hbase的table用起来确实就像是字典嵌套字典，太过于真实

这里我的表名为short，表有三个列族base、region、infos，这个是根据数据自己设计出来的。数据是个csv：如下，请先存为csv文件，导入你的mysql做准备（如果你要实验这个例子）

customer_id,first_name,last_name,email,gender,address,country,language,job,credit_type,credit_no
1,Spencer,Raffeorty,sraffeorty0@dropbox.com,Male,9274 Lyons Court,China,Khmer,Safety Technician III,jcb,3589373385487669
2,Cherye,Poynor,cpoynor1@51.la,Female,1377 Anzinger Avenue,China,Czech,Research Nurse,instapayment,6376594861844533
3,Natasha,Abendroth,nabendroth2@scribd.com,Female,2913 Evergreen Lane,China,Yiddish,Budget/Accounting Analyst IV,visa,4041591905616356
4,Huntley,Seally,hseally3@prlog.org,Male,694 Del Sol Lane,China,Albanian,Environmental Specialist,laser,677118310740263477
5,Druci,Coad,dcoad4@weibo.com,Female,16 Debs Way,China,Hebrew,Teacher,jcb,3537287259845047
6,Sayer,Brizell,sbrizell5@opensource.org,Male,71 Banding Terrace,China,Maltese,Accountant IV,americanexpress,379709885387687
7,Becca,Brawley,bbrawley6@sitemeter.com,Female,7 Doe Crossing Junction,China,Czech,Payment Adjustment Coordinator,jcb,3545377719922245
8,Michele,Bastable,mbastable7@sun.com,Female,98 Clyde Gallagher Pass,China,Malayalam,Tax Accountant,jcb,3588131787131504
9,Marla,Brotherhood,mbrotherhood8@illinois.edu,Female,4538 Fair Oaks Trail,China,Dari,Design Engineer,china-unionpay,5602233845197745479
10,Lionello,Gogarty,lgogarty9@histats.com,Male,800 Sage Alley,China,Danish,Clinical Specialist,diners-club-carte-blanche,30290846607043
11,Camile,Ringer,cringera@army.mil,Female,5060 Fairfield Alley,China,Punjabi,Junior Executive,china-unionpay,5602213490649878
12,Gillan,Banbridge,gbanbridgeb@wikipedia.org,Female,91030 Havey Point,China,Kurdish,Chemical Engineer,jcb,3555948058752802
13,Guinna,Damsell,gdamsellc@spiegel.de,Female,869 Ohio Park,China,Fijian,Analyst Programmer,jcb,3532009465228502
14,Octavia,McDugal,omcdugald@rambler.ru,Female,413 Forster Center,China,English,Desktop Support Technician,maestro,502017593120304035
15,Anjanette,Penk,apenke@lulu.com,Female,8154 Schiller Road,China,Swedish,VP Sales,jcb,3548039055836788
16,Maura,Teesdale,mteesdalef@globo.com,Female,9568 Quincy Alley,China,Dutch,Dental Hygienist,jcb,3582894252458217

导入mysql之后：

我是将它导在了数据库demo下面。

接下来，你就可以去玩蛇了

是不是感觉顺序混乱？？？混乱就对了

现在要干的事情是链接数据库读取数据，再将其插入到hbase中,mysql查表select，hbase插入put，知识点咚咚咚

mysql.py

[url=][/url]
1 #!/usr/bin/python 2 # coding:utf-8 3 import pymysql 4 import happybase 5 6 7 class testc: 8     def __init__(self, customer_id, first_name, last_name, email, gender, address, country, language, job, credit_type, 9                  credit_no):10         self._key = customer_id11         self._first_name = first_name12         self._last_name = last_name13         self._email = email14         self._gender = gender15         self._address = address16         self._country = country17         self._language = language18         self._job = job19         self._credit_type = credit_type20         self._credit_no = credit_no21 22     def get(self):23         return list((self._key, self._first_name, self._last_name,24                      self._email, self._gender, self._address,25                      self._country, self._language, self._job,26                      self._credit_type, self._credit_no)27                     )28 29     def __str__(self):30         return '%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s' % (self._key,31                                                      self._first_name,32                                                      self._last_name,33                                                      self._email,34                                                      self._gender,35                                                      self._address,36                                                      self._country,37                                                      self._language,38                                                      self._job,39                                                      self._credit_type,40                                                      self._credit_no41                                                      )42 43 44 connection = happybase.Connection('localhost', 9090)45 46 db = pymysql.connect(host='127.0.0.1', port=3307, user='root', password='hadoop', database='demo')47 cursor = db.cursor()48 49 sql = 'select * from testc'50 cursor.execute(sql)51 data = cursor.fetchall()52 data = list(data)53 datalist = []54 for i in range(0, len(data)):55     datalist.append(testc(data[0], data[1], data[2],56                           data[3], data[4], data[5],57                           data[6], data[7], data[8],58                           data[9], data[10]59                           ))60     print(datalist)61 # 到这里mysql中的表数据已经被读取并存储与datalist中，接下来将它转存在hbase中去62 table = connection.table('short')63 for data_ in datalist:64     row = data_.get()65     table.put(66         bytes('{}'.format(row[0]),encoding='ascii'),67         {68             b'base:first_name': bytes('{}'.format(row[1]), encoding='ascii'),69             b'base:last_name': bytes('{}'.format(row[2]), encoding='ascii'),70             b'base:email': bytes('{}'.format(row[3]), encoding='ascii'),71             b'base:gender': bytes('{}'.format(row[4]), encoding='ascii'),72             b'region:address': bytes('{}'.format(row[5]), encoding='ascii'),73             b'region:country': bytes('{}'.format(row[6]), encoding='ascii'),74             b'infos:language': bytes('{}'.format(row[7]), encoding='ascii'),75             b'infos:job': bytes('{}'.format(row[8]), encoding='ascii'),76             b'infos:credit_type': bytes('{}'.format(row[9]), encoding='ascii'),77             b'infos:credit_no': bytes('{}'.format(row[10]), encoding='ascii')78         }79     )80 81 db.close()[url=][/url]

大概流程思路是查出来的数据用特定格式做好，然后再写入，这里我做了个类（本质上没有必要）,读者在实验的时候可以考录直接使用一个list去接收

连接mysql就需要你使用pymysql库

db = pymysql.connect(host='127.0.0.1', port=3307, user='root', password='hadoop', database='demo')

其中的参数怕是意思很清楚了，这里不进行过多赘述。

这里有个叫做游标对象的东西  cursor = db.cursor() 可以认为他是个代理，使用它来执行sql语句并展示。

cursor有三个方法，fetchall、fetchone、fetchmany。嚼一嚼英语就知道意思是取全部、一行和多行，多行自然你要设定参数

找合适的容器接收你得到的数据，把数据按一定规格处理好之后，准备导入到hvase中。末尾的for循环就是导入代码，这里全部使用了bytes()是因为hbase只支持二进制，所以转换为了ascii码编码，否则你会在接下来的scan中看到不想要的utf-8字符。

导好了之后，我们使用scan来看一下，hbase中scan是用来看全表的，那么这里table对象就会同样有这个方法，人家老哥很厉害啊。

scan.py

[url=][/url]
1 #!/usr/bin/python 2 # coding:utf-8 3 4 import happybase 5 6 connection = happybase.Connection('localhost', 9090) 7 table = connection.table('short') 8 9 for key, data in table.scan():10     print(str(key),data)[url=][/url]

这个篇幅很小，因为表级操作。

这里是我查到的结果

这个小小的实验基本就完成了，中间遇到坑的时候可能会重复删表和建表，这里再提供一个

delete.py

[url=][/url]
1 #!/usr/bin/python2 # coding:utf-83 import happybase4 5 connection = happybase.Connection('localhost', 9090)6 connection.disable_table('short')7 connection.delete_table('short')[url=][/url]

有任何问题欢迎在评论区留言

或者添加学姐微信
DKA-2018