DataWorks:GetDIJob

O nome da fonte de dados.

O nome da fonte de dados.

O identificador do grupo de recursos do Data Integration usado para sincronização em lote.

O identificador do grupo de recursos do Data Integration usado para sincronização em tempo real.

O tipo de ação. Valores válidos:

• DefinePrimaryKey: define chaves primárias

• Rename: renomeia

• AddColumn: adiciona colunas

• HandleDml: processa DML

• DefineIncrementalCondition: define condições incrementais

• DefineCycleScheduleSettings: define configurações de agendamento periódico

• DefineRuntimeSettings: define parâmetros de configuração avançados

• DefinePartitionKey: define colunas de partição

A expressão da regra. A expressão é 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}: nome da fonte de dados de origem

    • ${srcDatabaseName}: nome do banco de dados de origem

    • ${srcTableName}: nome da tabela de origem

  • variables: a regra de geração para uma variável usada 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 conforme necessário.

    • variableName: o nome da variável. O nome da variável não é delimitado por ${}.

    • 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 indica a string original. to indica a nova string.

• Exemplo de uma regra usada para adicionar um campo específico ao destino e atribuir um valor ao campo: {"columns":\[{"columnName":"my_add_column","columnValueType":"Constant","columnValue":"123"}\]}.

  Se nenhuma regra deste tipo for configurada, nenhum campo será adicionado ao destino e nenhum valor será atribuído por padrão.

  • columnName: o nome do campo que é adicionado.

  • columnValueType: o tipo de valor do campo. Valores válidos: Constant e Variable.

  • columnValue: o valor do campo.

    • Se o valor do parâmetro columnValueType for Constant, o valor do parâmetro columnValue será uma constante do tipo de dados STRING.

    • Se o valor do parâmetro columnValueType for Variable, o valor do parâmetro columnValue será 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 indica o tempo de execução. DB_NAME_SRC indica o nome de um banco de dados de origem. DATASOURCE_NAME_SRC indica o nome da origem. TABLE_NAME_SRC indica o nome de uma tabela de origem. DB_NAME_DEST indica o nome de um banco de dados de destino. DATASOURCE_NAME_DEST indica o nome do destino. TABLE_NAME_DEST indica o nome de uma tabela de destino. DB_NAME_SRC_TRANSED indica o nome do banco de dados obtido após uma transformação.

• Exemplo de uma regra usada para especificar campos de chave primária para uma tabela de destino: {"columns":\["ukcolumn1","ukcolumn2"\]}.

  Se nenhuma regra deste tipo for configurada, os campos de chave primária na tabela de origem mapeada serão usados 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 contém 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 usada para processar mensagens DML: {"dmlPolicies":\[{"dmlType":"Delete","dmlAction":"Filter","filterCondition":"id > 1"}\]}.

  Se nenhuma regra deste tipo for configurada, a política de processamento padrão para mensagens geradas para operações de inserção, atualização e exclusão 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. O valor Filter é retornado para o parâmetro dmlAction apenas quando o valor do parâmetro dmlType for Update ou Delete.

  • filterCondition: a condição usada para filtrar mensagens DML. Este parâmetro é retornado apenas quando o valor do parâmetro dmlAction for Filter.

O nome da regra. Se os valores do parâmetro RuleActionType e do parâmetro RuleTargetType forem os mesmos para várias regras de transformação, você deve garantir que os nomes das regras de transformação sejam exclusivos.

O tipo do objeto no qual a ação é executada. Valores válidos:

• Table: tabela

• Schema: esquema

O tipo de sincronização que requer agendamento periódico. Valores válidos:

• Full: sincronização completa

• OfflineIncremental: sincronização incremental em lote

Os parâmetros de agendamento.