dpdispatcher.utils.dpcloudserver package

dpdispatcher.utils.dpcloudserver package#

class dpdispatcher.utils.dpcloudserver.Client(email=None, password=None, debug=False, ticket=None, base_url='https://bohrium.dp.tech/')[source]#

Bases: object

Methods

download

download_from_url

get

get_job_detail

get_job_result_url

get_log

get_tasks_list

job_create

kill

post

refresh_token

upload

download(oss_file, save_file, endpoint, bucket_name)[source]#
download_from_url(url, save_file)[source]#
get(url, header=None, params=None, retry=5)[source]#
get_job_detail(job_id)[source]#
get_job_result_url(job_id)[source]#
get_log(job_id)[source]#
get_tasks_list(group_id, per_page=30)[source]#
job_create(job_type, oss_path, input_data, program_id=None, group_id=None)[source]#
kill(job_id)[source]#
post(url, data=None, header=None, params=None, retry=5)[source]#
refresh_token(retry=3)[source]#
upload(oss_task_zip, zip_task_file, endpoint, bucket_name)[source]#

Submodules#

dpdispatcher.utils.dpcloudserver.client module#

class dpdispatcher.utils.dpcloudserver.client.Client(email=None, password=None, debug=False, ticket=None, base_url='https://bohrium.dp.tech/')[source]#

Bases: object

Methods

download

download_from_url

get

get_job_detail

get_job_result_url

get_log

get_tasks_list

job_create

kill

post

refresh_token

upload

download(oss_file, save_file, endpoint, bucket_name)[source]#
download_from_url(url, save_file)[source]#
get(url, header=None, params=None, retry=5)[source]#
get_job_detail(job_id)[source]#
get_job_result_url(job_id)[source]#
get_log(job_id)[source]#
get_tasks_list(group_id, per_page=30)[source]#
job_create(job_type, oss_path, input_data, program_id=None, group_id=None)[source]#
kill(job_id)[source]#
post(url, data=None, header=None, params=None, retry=5)[source]#
refresh_token(retry=3)[source]#
upload(oss_task_zip, zip_task_file, endpoint, bucket_name)[source]#
exception dpdispatcher.utils.dpcloudserver.client.RequestInfoException[source]#

Bases: Exception

dpdispatcher.utils.dpcloudserver.config module#

dpdispatcher.utils.dpcloudserver.retcode module#

class dpdispatcher.utils.dpcloudserver.retcode.RETCODE[source]#

Bases: object

DATAERR = '2002'#
DBERR = '2000'#
IOERR = '2003'#
NODATA = '2300'#
OK = '0000'#
PARAMERR = '2101'#
PWDERR = '2104'#
REQERR = '2200'#
ROLEERR = '2103'#
THIRDERR = '2001'#
TOKENINVALID = '2100'#
UNDERDEBUG = '2301'#
UNKOWNERR = '2400'#
USERERR = '2102'#
VERIFYERR = '2105'#

dpdispatcher.utils.dpcloudserver.zip_file module#

dpdispatcher.utils.dpcloudserver.zip_file.unzip_file(zip_file, out_dir='./')[source]#
dpdispatcher.utils.dpcloudserver.zip_file.zip_file_list(root_path, zip_filename, file_list=[])[source]#