DataWorks:PolarDB-X 2.0

Parâmetro

Descrição

Obrigatório

Padrão

datasource

Nome da fonte de dados. Deve corresponder exatamente ao nome configurado na página Data Source Management.

Sim

Nenhum

table

Tabela a ser sincronizada. Apenas uma única tabela é suportada por bloco de conexão.

Sim

Nenhum

column

Colunas a sincronizar, definidas como um array JSON. Use ["*"] para incluir todas as colunas. Não pode ficar em branco. Suporta seleção de colunas específicas, reordenação (a ordem não precisa coincidir com o schema da tabela) e constantes, seguindo a sintaxe SQL do PolarDB-X 2.0. Exemplo: ["id", "table", "1", "'mingya.wmy'", "'null'", "to_char(a+1)", "2.3", "true"].

Sim

Nenhum

splitPk

Coluna utilizada para particionamento de dados, permitindo leituras concorrentes. Defina como chave primária para garantir shards balanceados. Aceita apenas colunas do tipo inteiro — colunas de string, ponto flutuante e data são ignoradas, fazendo com que a leitura retorne a um único canal. Se deixado em branco ou omitido, a leitura ocorre por um único canal.

Não

Nenhum

where

Condição de filtro SQL WHERE para sincronização incremental. Por exemplo, gmt_create>$bizdate sincroniza apenas os dados do dia atual. Não pode ser definido como LIMIT 10. Se omitido, todos os dados serão sincronizados.

Não

Nenhum

checkSlave

Quando a fonte de dados é uma instância somente leitura, verifica o atraso de replicação antes do início da tarefa para evitar perda de dados.

Não

true

slaveDelayLimit

Atraso máximo de replicação permitido, em segundos. Caso o atraso real ultrapasse esse valor, a tarefa falhará.

Não

30

Parâmetro

Descrição

Obrigatório

Padrão

datasource

Nome da fonte de dados. Precisa corresponder ao nome configurado na página Data Source Management.

Sim

Nenhum

table

Nome da tabela de destino.

Sim

Nenhum

column

Colunas de destino para gravação, especificadas como um array JSON. Exemplo: ["id", "name", "age"]. Utilize ["*"] para gravar em todas as colunas respeitando a ordem do schema.

Sim

Nenhum

writeMode

Modo de tratamento de conflitos de escrita. Defina como insert (insert into) ou replace (replace into). Consulte Modos de escrita abaixo.

Não

insert

preSql

Instrução(ões) SQL a executar antes do início da tarefa — por exemplo, truncate table tablename;. Na interface sem código, apenas uma instrução é permitida. No editor de código, múltiplas instruções são suportadas, mas sem suporte a transações.

Não

Nenhum

postSql

Instrução(ões) SQL a executar após a conclusão da tarefa — por exemplo, adicionar uma coluna de timestamp. A interface sem código aceita somente uma instrução. O editor de código permite várias instruções, porém sem transações.

Não

Nenhum

batchSize

Quantidade de registros enviados por lote. Valores maiores reduzem idas e vindas na rede e melhoram o throughput, mas podem causar estouro de memória se configurados excessivamente altos.

Não

256

Modo

Valor no script

Comportamento em caso de conflito

insert into

insert

Se houver conflito de chave primária ou índice único, a linha conflitante é ignorada e registrada como dado sujo.

replace into

replace

Na ausência de conflitos, comporta-se igual ao insert into. Quando ocorre conflito, a linha existente é excluída e a nova linha é inserida, substituindo todos os campos.

Parâmetro

Descrição

Padrão

errorLimit.record

Número de registros com erro permitidos antes que a tarefa falhe.

"0"

speed.throttle

Indica se deve aplicar limite de taxa. Defina como true para ativar; false desativa o limite e torna o parâmetro mbps ineficaz.

true

speed.concurrent

Quantidade de canais concorrentes.

1

speed.mbps

Taxa máxima de sincronização em Mbps. Controla a pressão de leitura e gravação na origem e no destino. Só entra em vigor quando throttle estiver definido como true.

"12"