帝王谷资源网 Design By www.wdxyy.com
#!/usr/bin/env python # -*- coding:utf-8 -*- # ************************************* # @Time : 2019/8/12 # @Author : Zhang Fan # @Desc : Library # @File : MyDatabases.py # @Update : 2019/8/23 # ************************************* import elasticsearch import phoenixdb import pysolr import pymysql class MyELS(object): """ =================================================================== ===================== MyELS ========================= =================================================================== """ def __init__(self): self.els_conn = None def connect_to_els(self, host, port): """ 连接到ElasticSearch服务器. """ self.els_conn = elasticsearch.Elasticsearch([{'host': host, 'port': port}]) print('Executing : Connect To Elastic Search | %s' % self.els_conn) def get_els_data(self, query, index): """ 获取ElasticSearch数据 """ print('Executing : Search | %s' % query) try: rst = self.els_conn.search(index=index, q=query) return rst['hits'] except Exception as e: print('Elastic Search Error | %s' % e) raise Exception(e) class MyPhoenix(object): """ =================================================================== ===================== MyPhoenix ====================== =================================================================== """ def __init__(self): self.phoenix_conn = None self.phoenix_cursor = None def connect_to_phoenix(self, host, port=8765): """ 连接到phoenix服务器 """ address = 'http://{0}:{1}/'.format(host, port) print('Executing : Connect To Phoenix | %s' % address) self.phoenix_conn = phoenixdb.connect(address, autocommit=True) self.phoenix_cursor = self.phoenix_conn.cursor() def set_schema(self, sql, schema): """ 设置schema """ pre_sub, sub, fol_sub = sql.upper().partition('FROM') fol_sub = ' ' + schema + '.' + fol_sub.strip() new_sql = ''.join([pre_sub, sub, fol_sub]) return new_sql def execute_phoenix_sql(self, sql): """ 执行sql语句 """ # sql = self.set_schema(sql, schema) print('Executing : Execute | %s' % sql) self.phoenix_cursor.execute(sql) def get_from_phoenix(self, sql): """ 获取phoenix数据 """ # sql = self.set_schema(sql, schema) print('Executing : Query | %s' % sql) try: self.phoenix_cursor.execute(sql) except Exception as e: print('Phoenix Error | %s' % e) raise Exception(e) return self.phoenix_cursor.fetchall() def disconnect_from_phoenix(self): """ 断开phoenix连接 """ print('Executing : Disconnect From HBase') self.phoenix_cursor.close() self.phoenix_conn.close() class MySolr(object): """ =================================================================== ===================== MySolr ========================= =================================================================== """ def __init__(self): self.solr_conn = None self.base_url = None def connect_to_solr(self, address, selector): """连接到solr服务器. """ self.base_url = 'http://{0}/solr/{1}/'.format(address, selector) self.solr_conn = pysolr.Solr(self.base_url) print('Executing : Connect To Solr | %s' % self.base_url) def get_solr_data(self, query): """ 获取solr数据 """ results = list() print('Executing : Search | %s' % query) try: items = self.solr_conn.search(query) for item in items: results.append(item) except Exception as e: print('Solr Error | %s' % e) raise Exception(e) return results def add_solr_data(self, data): """ 添加solr数据 """ print('Executing : add | %s' % data) try: self.solr_conn.add([data]) self.solr_conn.commit() except Exception as e: print('Solr Error | %s' % e) raise Exception(e) def del_solr_byId(self, data): """ 删除solr数据 """ print('Executing : del | %s' % data) try: self.solr_conn.delete(id=data) self.solr_conn.commit() except Exception as e: print('Solr Error | %s' % e) raise Exception(e) if __name__ == '__main__': print('This is test.') ms = MySolr() me = MyELS() mp = MyPhoenix()
以上就是Python 调用 ES、Solr、Phoenix的示例代码的详细内容,更多关于Python 调用 ES、Solr、Phoenix的资料请关注其它相关文章!
帝王谷资源网 Design By www.wdxyy.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
帝王谷资源网 Design By www.wdxyy.com
暂无评论...
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
2024年12月24日
2024年12月24日
- 小骆驼-《草原狼2(蓝光CD)》[原抓WAV+CUE]
- 群星《欢迎来到我身边 电影原声专辑》[320K/MP3][105.02MB]
- 群星《欢迎来到我身边 电影原声专辑》[FLAC/分轨][480.9MB]
- 雷婷《梦里蓝天HQⅡ》 2023头版限量编号低速原抓[WAV+CUE][463M]
- 群星《2024好听新歌42》AI调整音效【WAV分轨】
- 王思雨-《思念陪着鸿雁飞》WAV
- 王思雨《喜马拉雅HQ》头版限量编号[WAV+CUE]
- 李健《无时无刻》[WAV+CUE][590M]
- 陈奕迅《酝酿》[WAV分轨][502M]
- 卓依婷《化蝶》2CD[WAV+CUE][1.1G]
- 群星《吉他王(黑胶CD)》[WAV+CUE]
- 齐秦《穿乐(穿越)》[WAV+CUE]
- 发烧珍品《数位CD音响测试-动向效果(九)》【WAV+CUE】
- 邝美云《邝美云精装歌集》[DSF][1.6G]
- 吕方《爱一回伤一回》[WAV+CUE][454M]