Atualiza uma tarefa de sincronização de nova versão. O seguinte tipo de tarefa é suportado: sincronização em tempo real de todos os dados de um banco de dados MySQL para o Hologres.
Experimente agora
Testar
Autorização RAM
Parâmetros da solicitação
|
Parâmetro |
Tipo |
Obrigatório |
Descrição |
Exemplo |
| DIJobId |
integer |
Não |
O ID da tarefa de sincronização. |
11588 |
| Description |
string |
Não |
A descrição da tarefa de sincronização. |
Synchronize MySQL to Hologres |
| ResourceSettings |
object |
Não |
As configurações de recursos. |
|
| OfflineResourceSettings |
object |
Não |
O recurso utilizado para sincronização em lote. |
|
| ResourceGroupIdentifier |
string |
Não |
O identificador do grupo de recursos do Data Integration utilizado para sincronização em lote. |
S_res_group_111_222 |
| RealtimeResourceSettings |
object |
Não |
O recurso utilizado para sincronização em tempo real. |
|
| ResourceGroupIdentifier |
string |
Não |
O identificador do grupo de recursos do Data Integration utilizado para sincronização em tempo real. |
S_res_group_111_222 |
| RequestedCu |
number |
Não |
O número de unidades de computação (CUs) no grupo de recursos utilizadas para sincronização completa e incremental. |
2.0 |
| TransformationRules |
array<object> |
Não |
A lista de regras de transformação que você deseja aplicar aos objetos de sincronização selecionados da origem. Cada entrada na lista define uma regra de transformação. |
|
|
object |
Não |
A regra de transformação que você deseja aplicar aos objetos de sincronização selecionados da origem. |
||
| RuleName |
string |
Não |
O nome da regra. Se os valores do parâmetro RuleActionType e do parâmetro RuleTargetType forem iguais para várias regras de transformação, você deve garantir que os nomes das regras de transformação sejam exclusivos. |
rename_rule_1 |
| RuleActionType |
string |
Não |
O tipo da ação. Valores válidos:
|
Rename |
| RuleTargetType |
string |
Não |
O tipo do objeto no qual você deseja executar a ação. Valores válidos:
|
Table |
| RuleExpression |
string |
Não |
A expressão da regra. A expressão deve ser uma string JSON. Exemplo de uma regra de renomeação: {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922","variables":[{"variableName":"srcDatabaseName","variableRules":[{"from":"fromdb","to":"todb"}]}]}. expression: a expressão da regra de renomeação. A expressão pode conter as seguintes variáveis: ${srcDatasourceName}, ${srcDatabaseName} e ${srcTableName}. ${srcDatasourceName} especifica o nome da origem. ${srcDatabaseName} especifica o nome de um banco de dados de origem. ${srcTableName} especifica o nome de uma tabela de origem. variables: a regra de geração para uma variável utilizada na expressão da regra de renomeação. O valor padrão da variável especificada é o valor original do objeto indicado pela variável. Você pode definir um grupo de regras de substituição de strings para alterar os valores originais com base nos seus requisitos de negócio. variableName: o nome da variável. Não coloque o nome da variável entre ${}. variableRules: as regras de substituição de strings para variáveis. O sistema executa as regras de substituição de strings em sequência. from especifica a string original. to especifica a nova string. Exemplo de uma regra utilizada para adicionar um campo específico ao destino e atribuir um valor ao campo: {"columns":[{"columnName":"my_add_column","columnValueType":"Constant","columnValue":"123"}]}. Se você não configurar essa regra, nenhum campo será adicionado ao destino e nenhum valor será atribuído por padrão. columnName: o nome do campo que você deseja adicionar. columnValueType: o tipo de valor do campo. Valores válidos: Constant e Variable. columnValue: o valor do campo que você deseja adicionar. Se você definir o parâmetro valueType como Constant, defina o parâmetro columnValue como uma constante personalizada do tipo STRING. Se você definir o parâmetro valueType como Variable, defina columnValue como uma variável integrada. As seguintes variáveis integradas são suportadas: EXECUTE_TIME (tipo de dados LONG), DB_NAME_SRC (tipo de dados STRING), DATASOURCE_NAME_SRC (tipo de dados STRING), TABLE_NAME_SRC (tipo de dados STRING), DB_NAME_DEST (tipo de dados STRING), DATASOURCE_NAME_DEST (tipo de dados STRING), TABLE_NAME_DEST (tipo de dados STRING) e DB_NAME_SRC_TRANSED (tipo de dados STRING). EXECUTE_TIME especifica o tempo de execução. DB_NAME_SRC indica o nome de um banco de dados de origem. DATASOURCE_NAME_SRC especifica o nome da origem. TABLE_NAME_SRC especifica o nome de uma tabela de origem. DB_NAME_DEST especifica o nome de um banco de dados de destino. DATASOURCE_NAME_DEST especifica o nome do destino. TABLE_NAME_DEST especifica o nome de uma tabela de destino. DB_NAME_SRC_TRANSED especifica o nome do banco de dados obtido após uma transformação. Exemplo de uma regra utilizada para especificar campos de chave primária para uma tabela de destino: {"columns":["ukcolumn1","ukcolumn2"]}. Se você não configurar essa regra, os campos de chave primária na tabela de origem mapeada serão utilizados para a tabela de destino por padrão. Se a tabela de destino for uma tabela existente, o Data Integration não modificará o esquema da tabela de destino. Se os campos de chave primária especificados não existirem na tabela de destino, um erro será reportado quando a tarefa de sincronização começar a ser executada. Se a tabela de destino for criada automaticamente pelo sistema, o Data Integration criará automaticamente o esquema da tabela de destino. O esquema conterá os campos de chave primária que você especificar. Se os campos de chave primária especificados não existirem na tabela de destino, um erro será reportado quando a tarefa de sincronização começar a ser executada. Exemplo de uma regra utilizada para processar mensagens DML: {"dmlPolicies":[{"dmlType":"Delete","dmlAction":"Filter","filterCondition":"id > 1"}]}. Se você não configurar essa regra, a política de processamento padrão para mensagens geradas por operações de insert, update e delete será Normal. dmlType: a operação DML. Valores válidos: Insert, Update e Delete. dmlAction: a política de processamento para mensagens DML. Valores válidos: Normal, Ignore, Filter e LogicalDelete. Filter indica processamento condicional. Você pode definir o parâmetro dmlAction como Filter somente quando o parâmetro dmlType estiver definido como Update ou Delete. filterCondition: a condição utilizada para filtrar mensagens DML. Este parâmetro é obrigatório somente quando o parâmetro dmlAction estiver definido como Filter. |
{"expression":"${srcDatasoureName}_${srcDatabaseName}"} |
| TableMappings |
array<object> |
Não |
A lista de mapeamentos entre regras utilizadas para selecionar objetos de sincronização na origem e regras de transformação aplicadas aos objetos de sincronização selecionados. Cada entrada na lista exibe um mapeamento entre uma regra utilizada para selecionar objetos de sincronização e uma regra de transformação aplicada aos objetos de sincronização selecionados. |
|
|
array<object> |
Não |
O mapeamento entre uma regra utilizada para selecionar objetos de sincronização na origem e uma regra de transformação aplicada aos objetos de sincronização selecionados. |
||
| SourceObjectSelectionRules |
array<object> |
Não |
A lista de regras que você deseja utilizar para selecionar objetos de sincronização na origem. |
|
|
object |
Não |
A regra que você deseja utilizar para selecionar objetos de sincronização na origem. Os objetos podem ser bancos de dados ou tabelas. |
||
| ObjectType |
string |
Não |
O tipo do objeto. Valores válidos:
|
Table |
| Expression |
string |
Não |
A expressão. |
mysql_table_1 |
| TransformationRules |
array<object> |
Não |
A lista de regras de transformação que você deseja aplicar aos objetos de sincronização selecionados da origem. |
|
|
object |
Não |
A regra de transformação que você deseja aplicar aos objetos de sincronização selecionados da origem. |
||
| RuleName |
string |
Não |
O nome da regra. Se os valores do parâmetro RuleActionType e do parâmetro RuleTargetType forem iguais para várias regras de transformação, você deve garantir que os nomes das regras de transformação sejam exclusivos. |
rename_rule_1 |
| RuleActionType |
string |
Não |
O tipo da ação. Valores válidos:
|
Rename |
| RuleTargetType |
string |
Não |
O tipo do objeto no qual você deseja executar a ação. Valores válidos:
|
Table |
| JobSettings |
object |
Não |
As configurações para a dimensão da tarefa de sincronização. As configurações incluem políticas de processamento para mensagens DDL, políticas para mapeamentos de tipos de dados entre campos de origem e campos de destino, e parâmetros de runtime da tarefa de sincronização. |
|
| DdlHandlingSettings |
array<object> |
Não |
As configurações para processamento de mensagens DDL. O valor deste parâmetro deve ser um array. |
|
|
object |
Não |
A configuração de processamento para um tipo específico de mensagem DDL. |
||
| Type |
string |
Não |
O tipo da operação DDL. Valores válidos:
|
AddColumn |
| Action |
string |
Não |
A política de processamento para mensagens DDL. Valores válidos:
|
Critical |
| ColumnDataTypeSettings |
array<object> |
Não |
As configurações para mapeamentos de tipos de dados entre campos de origem e campos de destino. O valor deste parâmetro deve ser um array. |
|
|
object |
Não |
O mapeamento de tipo de dados entre um campo de origem e um campo de destino. |
||
| SourceDataType |
string |
Não |
O tipo de dados de um campo de origem. |
bigint |
| DestinationDataType |
string |
Não |
O tipo de dados de um campo de destino. |
text |
| RuntimeSettings |
array<object> |
Não |
As configurações de runtime. O valor deste parâmetro deve ser um array. |
|
|
object |
Não |
As configurações de runtime. |
||
| Name |
string |
Não |
O nome do item de configuração. Valores válidos:
|
runtime.offline.concurrent |
| Value |
string |
Não |
O valor do item de configuração. |
1 |
| CycleScheduleSettings |
object |
Não |
As configurações para agendamento periódico. |
|
| ScheduleParameters |
string |
Não |
Os parâmetros de agendamento. |
bizdate=$bizdate |
| ChannelSettings |
string |
Não |
As configurações de controle de canal para a tarefa de sincronização. O valor deste parâmetro deve ser uma string JSON. |
{"structInfo":"MANAGED","storageType":"TEXTFILE","writeMode":"APPEND","partitionColumns":[{"columnName":"pt","columnType":"STRING","comment":""}],"fieldDelimiter":""} |
Elementos de resposta
|
Elemento |
Tipo |
Descrição |
Exemplo |
|
object |
O resultado retornado. |
||
| RequestId |
string |
O ID da solicitação. |
AAC30B35-820D-5F3E-A42C-E96BB6379325 |
Exemplos
Resposta de sucesso
JSON formato
{
"RequestId": "AAC30B35-820D-5F3E-A42C-E96BB6379325"
}
Códigos de erro
|
Código de status HTTP |
Código de erro |
Mensagem de erro |
Descrição |
|---|---|---|---|
| 500 | InternalError.System | An internal system error occurred. Try again later. | |
| 500 | InternalError.UserId.Missing | An internal system error occurred. Try again later. | |
| 429 | Throttling.Api | The request for this resource has exceeded your available limit. | |
| 429 | Throttling.System | The DataWorks system is busy. Try again later. | |
| 429 | Throttling.User | Your request is too frequent. Try again later. |
Consulte Códigos de Erro para uma lista completa.
Notas de versão
Consulte Notas de Versão para uma lista completa.