Changeset 873 for TI01-discovery
- Timestamp:
- 03/05/06 10:03:21 (15 years ago)
- Location:
- TI01-discovery/trunk/python
- Files:
-
- 1 added
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
TI01-discovery/trunk/python/discoveryWSinterface.py
r872 r873 1 #!/bin/env python 2 1 3 from ZSI import ServiceProxy 2 4 from ZSI.wstools.WSDLTools import WSDLReader 3 5 import sys 4 6 import os 5 7 import pdb 6 8 7 9 8 def browseService( ):10 def browseService(tracefile=sys.stdout): 9 11 10 12 sessID = None 11 13 try: 12 wr = WSDLReader() 13 wsdl = 'http://glue.badc.rl.ac.uk:8080/exist/services/Discovery?WSDL' 14 try: 15 wr = WSDLReader() 16 wsdl = 'http://glue.badc.rl.ac.uk:8080/exist/services/Discovery?WSDL' 17 18 srv = ServiceProxy(wsdl, use_wsdl=True, tracefile=tracefile) 19 20 #connectResp = srv.connect(in0='guest', in1='guest') 21 connectResp = srv.connect() 22 sessID = connectResp['connectReturn'] 23 24 print "________________________________________________________________________________" 25 print "Session ID \"%s\"" % sessID 26 print "________________________________________________________________________________" 27 # query = \ 28 # "//dgMetadata/dgMetadataRecord/dgMetadataID/schemeIdentifier[. = 'NDG-B0']" 29 # query = \ 30 # "//dgMetadata/dgMetadataRecord/dgMetadataID/localIdentifier[. = 'dataent1']" 31 32 # query = "acsoe" 33 # result = srv.xquery(in0=sessID, in1=query) 34 # result = srv.fullText(in0=sessID, in1=query) 35 # 36 # query = "acsoe" 37 # result = srv.xquery(in0=sessID, in1=query) 38 39 result = srv.spatialSearch(in0=sessID,in1=85.5,in2=-49.5,in3=166.5,in4=-9); 40 print "________________________________________________________________________________" 41 print "Spatial Search" 42 xqueryReturn=result['spatialSearchReturn'] 43 print "________________________________________________________________________________" 44 45 # Temporal Search 46 # result = srv.temporalSearch(in0=sessID,in1="1900-01-01",in2="2000-01-01"); 47 # xqueryReturn=result['temporalSearchReturn'] 48 49 50 for item in xqueryReturn.keys(): print item#,xqueryReturn[item] 51 52 # result = srv.getResource(in0=sessID, 53 # in1=u'/db/ndg_B_metadata/mcf_MDM_ACSOE_BV102_F.xml', 54 # in2=0,in3=0) 55 # print result 56 #works fine. 57 58 print 'QueryTime='+str(xqueryReturn['queryTime']) 59 print 'Hits='+str(xqueryReturn['hits']) 60 61 # hits=xqueryReturn['hits'][0] 62 63 howmany=1 64 start=1 65 highlight=u'none' 66 xinclude=1 67 indent=0 68 69 #range(10)*howmany 70 #for i in [j*howmany+1 for j in range(1+hits/howmany)]: 71 72 #nb need explicit keyword names!!! 73 sets=srv.retrieve(in0=sessID, 74 in1=start, 75 in2=howmany, 76 in3=indent, 77 in4=xinclude, 78 in5=highlight) 79 # 80 for item in sets.keys(): print item 81 82 print sets['retrieveReturn'] 83 84 85 return xqueryReturn 14 86 15 srv = ServiceProxy(wsdl, use_wsdl=True)# tracefile=sys.stdout) 16 print dir(srv) 17 18 #connectResp = srv.connect(in0='guest', in1='guest') 19 connectResp = srv.connect() 20 sessID = connectResp['connectReturn'] 21 22 #query = \ 23 # "//dgMetadata/dgMetadataRecord/dgMetadataID/schemeIdentifier[. = 'NDG-B0']" 24 #query = \ 25 # "//dgMetadata/dgMetadataRecord/dgMetadataID/localIdentifier[. = 'dataent1']" 26 27 #query = "acsoe" 28 #result = srv.xquery(in0=sessID, in1=query) 29 #result = srv.fullText(in0=sessID, in1=query) 30 31 #query = "acsoe" 32 #result = srv.xquery(in0=sessID, in1=query) 33 #result = srv.spatialSearch(in0=sessID,in1=85.5,in2=-49.5,in3=166.5,in4=-9); 34 result = srv.temporalSearch(in0=sessID,in1="1900-01-01",in2="2000-01-01"); 35 #xqueryReturn=result['spatialSearchReturn'] 36 xqueryReturn=result['temporalSearchReturn'] 37 for item in xqueryReturn.keys(): print item#,xqueryReturn[item] 38 39 # result = srv.getResource(in0=sessID, 40 # in1=u'/db/ndg_B_metadata/mcf_MDM_ACSOE_BV102_F.xml', 41 # in2=0,in3=0) 42 # print result 43 #works fine. 44 45 print 'QueryTime='+str(xqueryReturn['queryTime']) 46 print 'Hits='+str(xqueryReturn['hits']) 47 48 # hits=xqueryReturn['hits'][0] 49 50 howmany=1 51 start=1 52 highlight=u'none' 53 xinclude=1 54 indent=0 55 56 #range(10)*howmany 57 #for i in [j*howmany+1 for j in range(1+hits/howmany)]: 58 59 #nb need explicit keyword names!!! 60 sets=srv.retrieve(in0=sessID, 61 in1=start, 62 in2=howmany, 63 in3=indent, 64 in4=xinclude, 65 in5=highlight) 66 # 67 for item in sets.keys(): print item 68 69 print sets['retrieveReturn'] 70 71 72 73 return xqueryReturn 74 87 except Exception, e: 88 raise Exception(str(e)+os.linesep) 75 89 finally: 76 90 if sessID is not None: srv.disconnect(in0=sessID) … … 79 93 if __name__ == '__main__': 80 94 81 result=browseService( )95 result=browseService(tracefile=None) 82 96 #for item in result.keys(): 83 97 # print item,result[item]
Note: See TracChangeset
for help on using the changeset viewer.