dpdispatcher.dpcloudserver package

Submodules

dpdispatcher.dpcloudserver.api module

class dpdispatcher.dpcloudserver.api.API(email, password)[source]

Bases: object

Methods

check_job_has_uploaded

download

download_from_url

get

get_job_result_url

get_jobs

get_tasks

get_tasks_list

job_create

post

refresh_token

upload
check_job_has_uploaded(job_id)[source]
download(oss_file, save_file, endpoint, bucket_name)[source]
download_from_url(url, save_file)[source]
get(url, params, retry=0)[source]
get_job_result_url(job_id)[source]
get_jobs(page=1, per_page=10)[source]
get_tasks(job_id, group_id, page=1, per_page=10)[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]
post(url, params, retry=0)[source]
refresh_token()[source]
upload(oss_task_zip, zip_task_file, endpoint, bucket_name)[source]

dpdispatcher.dpcloudserver.config module

dpdispatcher.dpcloudserver.retcode module

class dpdispatcher.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.dpcloudserver.temp_test module

dpdispatcher.dpcloudserver.zip_file module

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