av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

Python 調用 ES、Solr、Phoenix的示例代碼

瀏覽:77日期:2022-07-04 15:05:32

#!/usr/bin/env python# -*- coding:utf-8 -*-# *************************************# @Time : 2019/8/12# @Author : Zhang Fan# @Desc : Library# @File : MyDatabases.py# @Update : 2019/8/23# *************************************import elasticsearchimport phoenixdbimport pysolrimport pymysqlclass 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的資料請關注好吧啦網其它相關文章!

標簽: Python 編程
相關文章:
主站蜘蛛池模板: 男女啪啪网址 | 国产a视频 | 精品1区2区3区4区 | 国产精品久久国产精品99 | 69堂永久69tangcom | 盗摄精品av一区二区三区 | 亚洲福利 | 国产精品日韩在线观看一区二区 | 午夜影视大全 | 成人国产在线视频 | 国产中文| 久久亚洲国产精品 | 欧美一级黄色免费看 | 国产 日韩 欧美 在线 | 日韩精品成人在线 | 国产精品成人在线观看 | 亚洲欧美在线观看 | 成人无遮挡毛片免费看 | 成人精品一区二区 | 成人一区精品 | 少妇黄色 | 男女国产视频 | 国产高清精品在线 | 中文字幕在线国产 | 久久人体视频 | 乱码av午夜噜噜噜噜动漫 | 成人影院在线 | 欧美成人精品 | 久久aⅴ乱码一区二区三区 亚洲欧美综合精品另类天天更新 | 成人二区 | 国产91在线精品 | 欧美中文在线 | 日韩视频国产 | 精久久久 | 久久久爽爽爽美女图片 | 伊人狠狠| 在线视频 中文字幕 | 99热热99| 国产视频h| 亚洲精品日本 | 国产欧美一区二区精品久导航 |