xuxiaohui9216 发表于 2018-11-1 12:56:25

从老solr导入新solr-expect批量同步数据

  #!/usr/bin/python
  import solr
  import re
  import urllib
  import pycurl
  import cStringIO
  import collections
  import operator
  import string
  import json
  import pysolr
  def solr_update(value):
  pass
  def function(value):
  value_1={}
  keys=value.keys()
  t1=value]
  t2=keys
  for ii in range(len(keys)-1):
  if t1 < value]:
  t1=value]
  t2=keys
  del value
  value_1=t1
  return (value_1,value)
  def dict_sort(value):
  result={}
  i=0
  while True:
  aaa=function(value)
  i+=1
  result=aaa
  if len(aaa) == 1:
  result=aaa
  break
  return result
  def solr_1(value):
  test_1='http://10.67.15.63:8800/solr/collection1/select?q=userid:'+value+'&wt=json&indent=true'
  buf=cStringIO.StringIO()
  c=pycurl.Curl()
  c.setopt(c.URL,test_1)
  c.setopt(c.WRITEFUNCTION,buf.write)
  c.perform()
  d=buf.getvalue()
  e=d.split('\n')
  for i in e:
  if i.find('numFound') != -1:
  num=i.split(":").split(",")
  num_1=num.split(" ")
  num_2=num_1.split("
页: [1]
查看完整版本: 从老solr导入新solr-expect批量同步数据