从老solr导入新solr-expect批量同步数据
#!/usr/bin/pythonimport 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]