API使用手册¶
-
class
sae.deferredjob.
MySQLImport
(storage_domain, filename, table_name='', callback_url='')¶ MySQL导入任务类
参数: - storage_domain – 存放导入文件的storage的domain名称
- filename – 导入文件名称,格式:prefix[.format][.compression],例:abc.csv.zip,服务根据format来判断数据类型,数据类型包括sql/csv
- table_name – 导入数据库使用的表名
- callback_url – 可选,任务成功时,调用的回调url,只支持应用默认版本中的url,为空时,不执行回调url
-
class
sae.deferredjob.
MySQLExport
(storage_domain, filename, table_name='', callback_url='')¶ MySQL导出任务类
参数: - storage_domain – 存放导出文件的storage的domain名称
- filename – 导出文件名称,格式:prefix[.format][.compression],例:abc.csv.zip,服务根据format来判断数据类型,数据类型包括sql/csv
- table_name – 导出数据库使用的表名
- callback_url – 可选,任务成功时,调用的回调url,只支持应用默认版本中的url,为空时,不执行回调url
-
class
sae.deferredjob.
DeferredJob
¶ DeferredJob类
-
add
(job)¶ 添加一个任务
参数: job – 需要添加的任务 返回: 调用成功时返回添加的任务id
-
status
(job_id)¶ 获取任务状态
参数: job_id – 需要获取的任务的id 返回: 调用成功时返回任务的状态:未进入队列:waiting;等待执行:inqueue;执行中:excuting;完成:done;失败:abort
-
delete
(job_id)¶ 删除任务
参数: job_id – 需要删除的任务的id 返回: 调用成功时返回True
-
-
sae.deferredjob.
add
(job)¶ 快速添加任务
参数: job – 需要添加的任务 返回: 调用成功时返回添加的任务id
使用示例¶
添加一个MySQL导入任务
from sae.deferredjob import MySQLImport, DeferredJob deferred_job = DeferredJob() job = MySQLImport('storage_test', 'test.sql.zip', 'test', '/job_done') deferred_job.add(job)
添加一个MySQL导出任务
from sae.deferredjob import MySQLExport, DeferredJob deferred_job = DeferredJob() job = MySQLExport('storage_test', 'test.sql.zip', 'test', '/job_done') deferred_job.add(job)
获取任务的状态
from sae.deferredjob import DeferredJob deferred_job = DeferredJob() print deferred_job.status(19999)
删除一个任务
from sae.deferredjob import DeferredJob deferred_job = DeferredJob() print deferred_job.delete(19999)
快速添加一个任务
from sae.deferredjob import add, MySQLImport job = MySQLImport('storage_test', 'test.sql.zip', 'test', '/job_done') add(job)