importtarfileimportrequestsbase_url="http:/127.0.0.1:9380/v1"defsubmit():uri="/job/submit"data={"dsl":{"components":{"reader_0":{"module":"Reader","output":{"data":["table"]}},"dataio_0":{"module":"DataIO","input":{"data":{"data":["reader_0.table"]}},"output":{"data":["train"],"model":["dataio"]},"need_deploy":True},"intersection_0":{"module":"Intersection","input":{"data":{"data":["dataio_0.train"]}},"output":{"data":["train"]}},"hetero_feature_binning_0":{"module":"HeteroFeatureBinning","input":{"data":{"data":["intersection_0.train"]}},"output":{"data":["train"],"model":["hetero_feature_binning"]}},"hetero_feature_selection_0":{"module":"HeteroFeatureSelection","input":{"data":{"data":["hetero_feature_binning_0.train"]},"isometric_model":["hetero_feature_binning_0.hetero_feature_binning"]},"output":{"data":["train"],"model":["selected"]}},"hetero_lr_0":{"module":"HeteroLR","input":{"data":{"train_data":["hetero_feature_selection_0.train"]}},"output":{"data":["train"],"model":["hetero_lr"]}},"evaluation_0":{"module":"Evaluation","input":{"data":{"data":["hetero_lr_0.train"]}},"output":{"data":["evaluate"]}}}},"runtime_conf":{"dsl_version":"2","initiator":{"role":"guest","party_id":20001},"role":{"guest":[20001],"host":[10001],"arbiter":[10001]},"job_parameters":{"common":{"task_parallelism":2,"computing_partitions":8,"task_cores":4,"auto_retries":1}},"component_parameters":{"common":{"intersection_0":{"intersect_method":"raw","sync_intersect_ids":True,"only_output_key":False},"hetero_lr_0":{"penalty":"L2","optimizer":"rmsprop","alpha":0.01,"max_iter":3,"batch_size":320,"learning_rate":0.15,"init_param":{"init_method":"random_uniform"}}},"role":{"guest":{"0":{"reader_0":{"table":{"name":"breast_hetero_guest","namespace":"experiment"}},"dataio_0":{"with_label":True,"label_name":"y","label_type":"int","output_format":"dense"}}},"host":{"0":{"reader_0":{"table":{"name":"breast_hetero_host","namespace":"experiment"}},"dataio_0":{"with_label":False,"output_format":"dense"},"evaluation_0":{"need_run":False}}}}}}}res=requests.post(base_url+uri,json=data)print(res.text)defstop():uri="/job/stop"data={"job_id":"202204251958539401540"}res=requests.post(base_url+uri,json=data)print(res.text)defrerun():uri="/job/rerun"data={"job_id":"202204251958539401540"}res=requests.post(base_url+uri,json=data)print(res.text)defquery():uri="/job/query"data={"job_id":"202204251958539401540"}res=requests.post(base_url+uri,json=data)print(res.text)deflist_job():uri="/job/list/job"data={"limit":1}res=requests.post(base_url+uri,json=data)print(res.text)defupdate():uri="/job/update"data={"job_id":"202204251958539401540","role":"guest","party_id":20001,"notes":"this is a test"}res=requests.post(base_url+uri,json=data)print(res.text)defparameter_update():uri="/job/parameter/update"data={"component_parameters":{"common":{"hetero_lr_0":{"max_iter":10}}},"job_parameters":{"common":{"auto_retries":2}},"job_id":"202204251958539401540"}res=requests.post(base_url+uri,json=data)print(res.text)defconfig():uri="/job/config"data={"job_id":"202204251958539401540"}res=requests.post(base_url+uri,json=data)print(res.text)deflog_download():uri="/job/log/download"data={"job_id":"202204251958539401540a"}download_tar_file_name="./test.tar.gz"res=requests.post(base_url+uri,json=data)withopen(download_tar_file_name,"wb")asfw:forchunkinres.iter_content(1024):ifchunk:fw.write(chunk)tar=tarfile.open(download_tar_file_name,"r:gz")file_names=tar.getnames()forfile_nameinfile_names:tar.extract(file_name)tar.close()deflog_path():uri="/job/log/path"data={"job_id":"202204251958539401540"}res=requests.post(base_url+uri,json=data)print(res.text)deftask_query():uri="/job/task/query"data={"job_id":"202204251958539401540","role":"guest","party_id":20001}res=requests.post(base_url+uri,json=data)print(res.text)deflist_task():uri="/job/list/task"data={"job_id":"202204251958539401540","role":"guest","party_id":20001}res=requests.post(base_url+uri,json=data)print(res.text)defjob_clean():uri="/job/clean"data={"job_id":"202204251958539401540","role":"guest","party_id":20001}res=requests.post(base_url+uri,json=data)print(res.text)defclean_queue():uri="/job/clean/queue"res=requests.post(base_url+uri)print(res.text)