国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

對python 操作solr索引數據的實例詳解

2020-02-15 23:59:26
字體:
來源:轉載
供稿:網友

測試代碼1:

def test(self):  data = {"add": {"doc": {"id": "100001", "*字段名*": u"我是一個大好人"}}}  params = {"boost": 1.0, "overwrite": "true", "commitWithin": 1000}  url = 'http://127.0.0.1:8983/solr/mycore/update?wt=json'  headers = {"Content-Type": "application/json"}  r = requests.post(url, json=data, params=params, headers=headers)  print r.text def Index_data(self):  solr = pysolr.Solr('http://127.0.0.1:8983/solr/mycore/', timeout=10)  # How you'd index data.  result = solr.add([   {    "id": "doc_1",    "title": "A test document",   },   {    "id": "doc_2",    "title": "The Banana: Tasty or Dangerous?",   },  ])  print result

測試代碼2:

實際數據:

python 操作solr索引數據

def Index_Data_FromCSV(self, csvfile):  '''   從CSV文件中讀取數據,并索引到solr中   :param csvfile: csv文件,包括完整路徑   :return:   '''  list = CSVOP.ReadCSV(csvfile)  index = 0  doc = {}  params = {"boost": 1.0, "overwrite": "true", "commitWithin": 1000}  url = 'http://127.0.0.1:8983/solr/mycore/update?wt=json'  headers = {"Content-Type": "application/json"}  for item in list:   if index > 0: # 第一行是標題    try:     doc['title'] = item[0].decode('GB2312')     doc['link'] = item[1]     # doc['date'] = item[2]     doc['source'] = item[3].decode('GB2312')     doc['keyword'] = item[4].decode('GB2312')     data = {"add": {"doc": doc}}     r = requests.post(url, json=data, params=params, headers=headers)     print r.text    except Exception,e:     print e.message   print index   index += 1#pysolr客戶端代碼 def pysolr_Index_Data_FromCSV(self, csvfile,url='http://127.0.0.1:8983/solr/mycore/'):  '''   從CSV文件中讀取數據,并索引到solr中   :param csvfile: csv文件,包括完整路徑   :return:   '''  list = CSVOP.ReadCSV(csvfile)  index = 0  listdocs = []  for item in list:   if index > 0: # 第一行是標題    doc = {}    try:     doc['title'] = item[0].decode('GB2312')     doc['link'] = item[1]     # doc['date'] = item[2]     doc['source'] = item[3].decode('GB2312')     doc['keyword'] = item[4].decode('GB2312')     listdocs.append(doc)    except Exception,e:     print e.message   index += 1  solr = pysolr.Solr(url, timeout=10)  result = solr.add(listdocs)  print result

查詢代碼:

def search_data(self,message='視頻'):  url = 'http://127.0.0.1:8983/solr/mycore/select?q=title:"/%s"&wt=json&indent=true' % message  r = requests.get(url, verify=False)  print r.text  r = r.json()['response']['numFound']  print message + ":" + str(r)    #pysolr客戶端  def search_data(self,where='視頻',url='http://127.0.0.1:8983/solr/mycore/'):  solr = pysolr.Solr(url, timeout=10)  dict = {'start':10,'rows': 30,'fl':'title,keyword,source,link'}  result = solr.search('title:視頻',**dict)  # result = solr.search('title:視頻')  # print result.raw_response['response']['numFound']  for item in result:   print 'keyword: %s'% item['keyword']   print 'title: %s'% item['title']   print 'source: %s'% item['source']   print 'link: %s'% item['link']   print '             
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 隆子县| 霞浦县| 河池市| 且末县| 家居| 曲水县| 紫阳县| 连江县| 高陵县| 收藏| 潼关县| 皮山县| 顺平县| 抚州市| 赫章县| 通道| 崇仁县| 曲沃县| 万山特区| 湟中县| 卢氏县| 彝良县| 鄂托克旗| 广南县| 乐至县| 玉田县| 淮阳县| 连州市| 封开县| 镇原县| 彰化市| 宽甸| 萨嘎县| 姜堰市| 徐水县| 嘉祥县| 浮梁县| 大足县| 大足县| 获嘉县| 东安县|