1特征服务，一般不开放接口
2same_private_example.py
3#!/usr/bin/env python
4#coding:utf-8
5import os
6import os.path
7import json
8import sys
9import urllib
10import urllib2
11import base64
12from proto import imgfeature_pb2
13import logging
14import time
15import subprocess
16import random
17logger = logging.getLogger()
18
19
20class CalFeatureError(Exception):
21    """when call remote server error"""
22    pass
23
24def calfeature_idlapi_remote(serverurl, imagedata, infos, logid=0):
25    """ cropmethod will pass to server as alignflag parameter"""
26
27    def _createprotobufdata(imagestr, info):
28        """create protobuf from image and info"""
29        proto_data = imgfeature_pb2.FeatureRequest()
30        proto_data.image = imagestr
31        proto_data.query_sign = '0,0'
32
33        def addinfo(key, value):
34            """add info to proto"""
35            infoele = proto_data.info.texts.add()
36            infoele.key = key
37            infoele.value = value
38
39        if info is not None:
40            for key, value in info.iteritems():
41                addinfo(key, value)
42        data = proto_data.SerializeToString()
43        return data
44
45    protodata = _createprotobufdata(imagedata, infos)
46    protodata = base64.b64encode(protodata)
47    req_json = {
48        'appid': "123456",
49        'logid': logid,
50        'format': 'json',
51        'from': 'test-python',
52        'cmdid': '123',
53        'clientip': '0.0.0.0',
54        'data': protodata,
55    }
56
57    conn = urllib2.urlopen(serverurl, data=json.dumps(req_json))
58    resultjson = conn.read()
59    result = json.loads(resultjson)
60    if result['err_no'] != 0:
61        errorinfo = '%s:%s' % (result['err_no'], result['err_msg'])
62        logger.warn('got error from server:%s', errorinfo)
63        raise CalFeatureError(errorinfo)
64
65    res_data = result['result'].decode('base64')
66    proto_result = imgfeature_pb2.FeatureResponse()
67    proto_result.ParseFromString(res_data)
68    features = {fea.fea_id: fea.fea_data for fea in proto_result.features}
69    return features
70
71def calfeature_remote(filename, feaaddr, featureids=''):
72    import urllib2
73    feaserverurl = 'http://%s/GeneralClassifyService/classify' % (feaaddr)
74    param = {"detect": "1", "usedb": "0"}
75    imagedata = open(filename, 'rb').read()
76    start = time.time()
77    features = calfeature_idlapi_remote(feaserverurl, imagedata, params)
78    print "time cost: %.2f ms" % ((time.time() - start)*1000)
79    for feaname in features:
80        print "-------------"*5
81        print feaname, features[feaname], len(features[feaname])
82
83def main():
84    img_path = 'query.jpg'
85    calfeature_remote(img_path,'127.0.0.1:8120','')
86    pass
87
88if __name__ == '__main__':
89    if len(sys.argv)>1 :
90        func = getattr(sys.modules[__name__], sys.argv[1])
91        func(*sys.argv[2:])
92    else:
93        print >> sys.stderr,'tools.py command'

1same_private_example_add_remove.py:
2#coding:utf-8
3import urllib2
4import base64
5import json
6import os
7import sys
8import logging
9logger = logging.getLogger()
10
11AS_SERVER = 'http://10.255.140.17:8027'
12
13ADD_IMG = 'query.jpg'
14APPID='test'  
15
16
17def rts_as_add(filename=ADD_IMG, appid=APPID):
18    params = {
19        "appid": appid,
20        "format": "json",
21        "from": "from_xx",
22        "logid": 666,
23        "brief": "brief",
24        "image": base64.b64encode(open(filename,'rb').read()),
25        "features": [{"fea_id":1000, "fea_data" : base64.b64encode("addtest")}, {"fea_id":999, "fea_data": base64.b64encode(struct.pack('II', 0, 4))}]
26    }
27    conn = urllib2.urlopen(AS_SERVER+'/RTSAsService/add', data=json.dumps(params)).read()
28    print conn
29
30def rts_as_update(filename=IMG, appid=APPID):
31    params = {
32        "appid": appid,
33        "format": "json",
34        "from": "from_xx",
35        "logid": 666,
36        "image": base64.b64encode(open(filename,'rb').read()),
37        "features": [{"fea_id":1000, "fea_data" : base64.b64encode("addtest")}]
38    }
39    conn = urllib2.urlopen(AS_SERVER+'/RTSAsService/update', data=json.dumps(params)).read()
40    print conn
41
42def rts_as_search(filename=IMG, appid=APPID):
43    params = {
44        "appid": appid,
45        "image": base64.b64encode(open(filename,'rb').read()),
46        "format": "json",
47        "from": "from_yyy",
48        "logid": 44,
49    }
50    conn = urllib2.urlopen(AS_SERVER+'/RTSAsService/search', data=json.dumps(params)).read()
51    print conn
52
53def rts_as_delete(contsign, appid=APPID):
54    sign1, sign2 = map(int,contsign.split(','))
55
56    params = {
57        "appid": appid,
58        "format": "json",
59        "from": "from_xx",
60        "logid": 666,
61        #"image": base64.b64encode(open('1.jpg','rb').read()),
62        "contsign" : {'sign1':sign1,"sign2":sign2},
63    }
64    conn = urllib2.urlopen(AS_SERVER+'/RTSAsService/remove', data=json.dumps(params)).read()
65    print conn
66
67def rts_as_snapshot(appid=APPID):
68    params = {
69        "appid": appid,
70        "from": "from_xx",
71        "logid": 666,
72    }
73    conn = urllib2.urlopen(AS_SERVER+'/RTSAsService/snapshot', data=json.dumps(params)).read()
74    print conn;
75
76def signup(appid=APPID):
77    params = {
78        "appid": appid,
79        "from": "from_xx",
80        "logid": 666,
81    }
82    conn = urllib2.urlopen(AS_SERVER+'/RTSAsService/signup', data=json.dumps(params)).read()
83    print conn;
84
85if __name__ == '__main__':
86    if len(sys.argv) > 1:
87        func = getattr(sys.modules[__name__], sys.argv[1])
88        func(*sys.argv[2:])
89    else:
90        print >> sys.stderr, 'api.py {rts_as_add,rts_as_search,rts_as_delete}'