resty

Client side kit for use with restAssured.

Resty handles CRUD operations for data, files, even blobs

Sample Usage:

• First step is including resty in your project so that your project space looks like this: projectSrc/ resty <rest_of_code> ...

• Next step is using resty in your code.

• This example assumes that for successful running, you have cloned and are running

restAssured

on the ip and port that you will provide when running sampleResty.py

• Also it runs code from restAssured projects jobTable which saves jobs that are pushed up

and will later on be assigned to different workers. Also the example shows how to use the

file handling service with restAssured.

• vi sampleResty.py

    #!/usr/bin/env python
  
    import os
    from resty import restDriver
  
    getDefaultAuthor = lambda: os.environ.get('USERNAME', 'Anonymous')
  
    def main():
        port = '8000'
        address = 'http://127.0.0.1'
  
        restDriver = RestDriver(address, port)
  
        # First step is registering a liason by its referral name eg 'Job',
          and then it's handler uri. 
        # After registration, referring to the CRUD handlers of the liason will be as simple
        # as invoking eg newJob, getJobs, updateJobs, deleteJobs
  
        restDriver.registerLiason('Job', '/jobTable/jobHandler')
        restDriver.registerLiason('Worker', '/jobTable/workerHandler')
  
        print(restDriver.newWorker(name='SpeedBuggy', purpose='Individual Checks'))
        print(restDriver.newJob(
            message='TheStrokes-Someday', author=getDefaultAuthor(), assignedWorker_id=1
        ))
  
        print(restDriver.updateWorkers(
            queryParams=dict(name='SpeedBuggy'), updatesBody=dict(purpose='Crawling Speed checks')
        ))
  
        print('Updating', restDriver.updateJobs(
            queryParams=dict(message='TheStrokes-Someday'), updatesBody=dict(status='finished')
        ))
  
        # Handling D for Jobs and Workers
        print(restDriver.deleteJobs())
        print(restDriver.deleteWorkers())
  
        # Handling G for file handling app
        print(restDriver.getCloudFilesManifest(select='size,checkSum'))
  
        # Handling D for file handling app
        print(restDriver.deleteBlob(title='collabFib'))
  
        restDriver.registerLiason('Artist', '/thebear/artistHandler')
        print(restDriver.newArtist(name='Tester'))
  
    if __name__ == '__main__':
        main()
  

• This next example steps you through using resty & restAssured to save pickled/serialized

• data as a blob and then later re-using it in after deserialization.

    * Sample usage might be in collaborative computing ie publish results from an expensive
  
    * computation on one machine so that other machines can load it as live data.
  
    + vi blobStore.py
  
    #!/usr/bin/env python3
  
    def testSerializer():
        import Serializer
        bs = Serializer.BinarySerializer()
        js = Serializer.JSONSerializer()
        data = dict((i, i) for i in range(100))
        bserial = bs.serialize(data)
        jserial = js.serialize(data)
  
        bdserial = bs.deserialize(bserial)
        jdserial = js.deserialize(jserial)
        print('bdserial', bdserial)
        ioS = bs.ioStream(bserial)
        print('ioS', ioS.read())
  
    def testCloudPassagePickledVersion():
        import ___cloudPassage
        cc = ___cloudPassage.CloudPassageHandler()
        data = dict((i, i*10) for i in range(9))
        title = 'Dict of items 0-8999, keys i*10'
        res = cc.push(data, title=title, asPickle=True)
        pulledObj = cc.pull(metaData='pickle')
  
        print('PulledObj', pulledObj, data)
        assert(pulledObj == data)
  
        rmTry = cc.removeTrace(data, asPickle=True)
        print(rmTry)
  
    def testCloudPassageJSONVersion():
        import ___cloudPassage
        cc = ___cloudPassage.CloudPassageHandler()
        data = dict((str(i), i*10) for i in range(9))
        title = 'Dict of items 0-8999, keys i*10'
        res = cc.push(data, title=title, asPickle=False)
        pulledObj = cc.pull(metaData='json')
  
        print('PulledObj', pulledObj, data)
        assert(pulledObj == data)
  
        rmTry = cc.removeTrace(data)
        print(rmTry)
  
    def main():
        testSerializer()
        testCloudPassageJSONVersion()
        testCloudPassagePickledVersion()
  
    if __name__ == '__main__':
        main()