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

xuxiaohui9216

　　#!/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[keys[0]]
　　t2=keys[0]
　　for ii in range(len(keys)-1):
　　if t1 < value[keys[ii+1]]:
　　t1=value[keys[ii+1]]
　　t2=keys[ii+1]
　　del value[t2]
　　value_1[t2]=t1
　　return (value_1,value)
　　def dict_sort(value):
　　result={}
　　i=0
　　while True:
　　aaa=function(value)
　　i+=1
　　result=aaa[0]
　　if len(aaa[1]) == 1:
　　result=aaa[1]
　　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(":")[1].split(",")[0]
　　num_1=num.split(" ")
　　num_2=num_1[0].split("