Commit 2d27caf4 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Modified transfer request json sample. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent 7727342a

client/vos_rest_client.py

+41 −14
Original line number Diff line number Diff line
@@ -8,7 +8,7 @@ class AMQPClient(object): 


    def __init__(self, rpcQueue):

        self.rpcQueue = rpcQueue

        self.connection = pika.BlockingConnection(pika.ConnectionParameters(host = 'rabbitmq'))

        self.connection = pika.BlockingConnection(pika.ConnectionParameters(host = "rabbitmq"))

        self.channel = self.connection.channel()

        result = self.channel.queue_declare(queue = '', exclusive = True)

        self.callback_queue = result.method.queue
@@ -35,29 +35,56 @@ class AMQPClient(object): 


if len(sys.argv) == 2:

    script, queue = sys.argv

    if queue not "start_job_queue":

        sys.exit("FATAL: wrong number of input args.")  

elif len(sys.argv) == 3:

    script, queue, jobid = sys.argv

    if queue not "poll_job_queue":

        sys.exit("FATAL: wrong number of input args.")

else:

    sys.exit("FATAL: wrong number of input args.")



if queue == 'start_job_queue':

if queue == "start_job_queue":

    testClient = AMQPClient(queue)

    transferRequest = { "transfer":

                         {

                            "@version": "2.1",

    transferRequest = {

        "jobId": str(uuid.uuid1().hex),

        "runId": None,

        "ownerId": "anonymous",

        "phase": "PENDING",

        "quote": None,

        "creationTime": None,

        "startTime": None,

        "endTime": None,

        "executionDuration": 0,

        "destruction": None,

        "parameters": None,

        "results": [],

        "errorSummary": None,

        "jobInfo": {

            "transfer": {

                "target": "vos://example.com!vospace/mydata1",

                            "direction": "pullFromVoSpace",

                            "protocol": {

                               "@uri": "ivo://ivoa.net/vospace/core#httpget"

                "direction": "pullToVoSpace",

                "view": None,

                "protocol": [

                    {

                        "endpoint": None,

                        "param": [],

                        "uri": "ia2:tape-recall"

                    }

                ],

                "keepBytes": None,

                "version": None

            }

        },

        "version": None

    }



    print("Sending transfer request:")

    print(json.dumps(transferRequest, indent = 3))

    response = testClient.call(transferRequest)

    print("Response:")

    print(json.dumps(response, indent = 3))

elif queue == 'poll_job_queue':

elif queue == "poll_job_queue":

    testClient = AMQPClient(queue)

    pollRequest = { "jobId": jobid }

    print("Sending poll request:")