调用CreateImportMigration创建导入任务，导入任务包含数据源信息、任务、表等对象的DataWorks导入导出包。
注意：本接口导入文件涉及文件上传，方式调用举例如下：
Config config = new Config();
config.setAccessKeyId(accessId);
config.setAccessKeySecret(accessKey);
config.setEndpoint(popEndpoint);
config.setRegionId(regionId);
Client client = new Client(config);
CreateImportMigrationAdvanceRequest request = new CreateImportMigrationAdvanceRequest();
request.setName(“test_migration_api_” + System.currentTimeMillis());
request.setProjectId(123456L);
request.setPackageType(“DATAWORKS_MODEL”);
request.setPackageFileObject(new FileInputStream(“/home/admin/Downloads/test.zip”));
RuntimeOptions runtime = new RuntimeOptions();
CreateImportMigrationResponse response = client.createImportMigrationAdvance(request, runtime);
…
调试
您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。
请求参数
| 名称 | 类型 | 是否必选 | 示例值 | 描述 |
|---|---|---|---|---|
| Action | String | 是 | CreateImportMigration |
要执行的操作。 |
| CalculateEngineMap | String | 是 | { “ODPS”: { “zxy_8221431_engine”: “wzp_kaifazheban_engine” }, “EMR”: { “aaaa”: “bbb” } } |
导入任务中，导入的源计算引擎到导出的目标计算引擎实例的映射关系。 计算引擎的类型，包括ODPS、EMR、HADOOP_CDH、HOLOGRES等。 |
| CommitRule | String | 是 | { “resourceAutoCommit”: false, “resourceAutoDeploy”: false, “functionAutoCommit”: false, “functionAutoDeploy”: false, “tableAutoCommitToDev”: false, “tableAutoCommitToProd”: false, “ignoreLock”: false, “fileAutoCommit”: false, “fileAutoDeploy”: false } |
执行导入操作时，设定的自动提交发布任务的规则。参数如下：
|
| Name | String | 是 | test_import_001 |
创建的导入任务的名称。项目空间内该名称必须唯一。 |
| PackageFile | String | 是 | /home/admin/xxx/import.zip |
导入包文件路径。 注意：本接口导入文件涉及文件上传。方式调用举例如下： Client client = new Client(config); CreateImportMigrationAdvanceRequest request = new CreateImportMigrationAdvanceRequest(); RuntimeOptions runtime = new RuntimeOptions(); |
| PackageType | String | 是 | DATAWORKS_MODEL |
导入导出包的类型，取值如下：
|
| ProjectId | Long | 是 | 123456 |
DataWorks工作空间的ID。您可以登录DataWorks管控台，进入工作空间配置页面获取工作空间ID。 |
| RegionId | String | 是 | cn-shanghai-fiance-1 |
地域信息，通常为服务所在的地域。例如，华东2（上海）为cn-shanghai，华北3（张家口）为cn-zhangjiakou。您无需填写RegionId，会根据调用的Endpoint自动解析。 |
| ResourceGroupMap | String | 否 | {“SCHEDULER_RESOURCE_GROUP”: {“xxx”:”yyy”},”DI_RESOURCE_GROUP”:{“ccc”:”ddd”}} |
调度资源组和数据集成资源组的映射关系。映射的key和value均为资源组的标识符（identifier）， 格式如下： |
| WorkspaceMap | String | 否 | {“test_workspace_src”: “test_workspace_target”} |
用于在执行导入导出操作时，根据该映射关系，修改导入导出包里的输入输出项目空间名称为映射后的项目空间名称。例如，导入时会根据映射关系，把输入输出里的项目空间名称的前缀做相应替换。 |
| Description | String | 否 | test description |
导入导出包的描述信息。 |
返回数据
| 名称 | 类型 | 示例值 | 描述 |
|---|---|---|---|
| Data | Long | 123456 |
导入导出包ID。作为后续执行导入任务或获取导入任务执行进度的入参。 |
| ErrorCode | String | 110001123456 |
错误码。 |
| ErrorMessage | String | test error message |
错误信息。 |
| HttpStatusCode | Integer | 200 |
HTTP状态码。 |
| RequestId | String | ADFASDFASDFA-ADFASDF-ASDFADSDF-AFFADS |
请求的ID。用于定位日志，排查问题。 |
| Success | Boolean | true |
调用是否成功。 |
示例
请求示例
http(s)://[Endpoint]/?Action=CreateImportMigration
&CalculateEngineMap={ "ODPS": { "zxy_8221431_engine": "wzp_kaifazheban_engine" }, "EMR": { "aaaa": "bbb" } }
&CommitRule={ "resourceAutoCommit": false, "resourceAutoDeploy": false, "functionAutoCommit": false, "functionAutoDeploy": false, "tableAutoCommitToDev": false, "tableAutoCommitToProd": false, "ignoreLock": false, "fileAutoCommit": false, "fileAutoDeploy": false }
&Name=test_import_001
&PackageFile=/home/admin/xxx/import.zip
&PackageType=DATAWORKS_MODEL
&ProjectId=123456
&RegionId=cn-shanghai-fiance-1
&正常返回示例
XML格式
ADFASDFASDFA-ADFASDF-ASDFADSDF-AFFADS
200
123456
110001123456
test error message
trueJSON格式
{
"RequestId": "ADFASDFASDFA-ADFASDF-ASDFADSDF-AFFADS",
"HttpStatusCode": 200,
"Data": 123456,
"ErrorCode": 110001123456,
"ErrorMessage": "test error message",
"Success": true
}错误码
访问错误中心查看更多错误码。
内容没看懂？ 不太想学习？想快速解决？ 有偿解决： 联系专家
阿里云企业补贴进行中： 马上申请
腾讯云限时活动1折起，即将结束： 马上收藏
同尘科技为腾讯云授权服务中心。
购买腾讯云产品享受折上折，更有现金返利:同意关联，立享优惠
转转请注明出处：https://www.yunxiaoer.com/171231.html
