Consultar informações da tarefa de entrega - Tablestore SDK for Java - Tablestore: Central de Documentação do Alibaba Cloud

Pré-requisitos

Instale o Tablestore SDK for Java e inicialize um client. A entrega de dados exige a versão 5.10.3 ou posterior. Recomendamos o uso da versão mais recente.

Descrição

Chame describeDeliveryTask para consultar a configuração e o status de execução de uma tarefa de entrega.

public DescribeDeliveryTaskResponse describeDeliveryTask(DescribeDeliveryTaskRequest request)
        throws TableStoreException, ClientException

O exemplo a seguir consulta a tarefa de entrega example_task na tabela de dados example_table e imprime o tipo de tarefa, o prefixo do diretório do OSS e a fase de sincronização. client é um client inicializado.

String tableName = "example_table";
String taskName = "example_task";
DescribeDeliveryTaskRequest request =
        new DescribeDeliveryTaskRequest(tableName, taskName);

DescribeDeliveryTaskResponse response = client.describeDeliveryTask(request);
System.out.println("taskType: " + response.getTaskType());
System.out.println("ossPrefix: " + response.getTaskConfig().getOssPrefix());
System.out.println("taskSyncPhase: "
        + response.getTaskSyncStat().getTaskSyncPhase());

Parâmetros

request é do tipo DescribeDeliveryTaskRequest e contém os seguintes parâmetros.

Nome	Tipo	Descrição
tableName (obrigatório)	String	Nome da tabela de dados.
taskName (obrigatório)	String	Nome da tarefa de entrega.

Resposta

O método retorna um objeto DescribeDeliveryTaskResponse com os seguintes campos de negócio.

Nome	Tipo	Descrição
taskConfig	OSSTaskConfig	Configuração de entrega do OSS.
taskSyncStat	TaskSyncStat	Status de sincronização da tarefa de entrega.
taskType	DeliveryTaskType	Tipo da tarefa de entrega. Valores válidos: `BASE` para entrega completa, `INC` para entrega incremental e `BASE_INC` para entrega completa seguida de entrega incremental contínua.

Configuração de entrega do OSS

taskConfig é do tipo OSSTaskConfig e contém os seguintes campos.

Nome	Tipo	Descrição
ossPrefix	String	Prefixo do diretório no bucket do OSS.
ossBucket	String	Nome do bucket do OSS.
ossEndpoint	String	Endpoint da região onde está localizado o bucket do OSS.
ossStsRole	String	ARN da função vinculada ao service `AliyunServiceRoleForOTSDataDelivery`.
parquetSchema	List<ParquetSchema>	Campos entregues. A ordem dos elementos corresponde à ordem dos campos nos arquivos Parquet.
eventTimeColumn	EventColumn	Coluna de tempo do evento. Este campo fica vazio se nenhuma coluna de tempo do evento tiver sido configurada.
format	OSSFileFormat	Formato de arquivo do OSS. Valor atual: `Parquet`.
timeFormatter	TimeFormatter	Formato de partição do OSS. Valor atual: `YDMFormatter`, que representa o formato ano-mês-dia.

Campos entregues

Cada elemento em taskConfig.parquetSchema[] é do tipo ParquetSchema e contém os seguintes campos.

Nome	Tipo	Descrição
columnName	String	Nome do campo de source na tabela de dados do Tablestore.
ossColumnName	String	Nome do campo após a entrega no OSS.
type	DataType	Tipo de destino do campo no arquivo Parquet.
encode	OSSFileEncoding	Codificação do Parquet.
typeExtend	String	Tipo estendido do Parquet. Recurso não suportado; o campo permanece vazio.

Coluna de tempo do evento

taskConfig.eventTimeColumn é do tipo EventColumn e contém os seguintes campos.

Nome	Tipo	Descrição
columnName	String	Nome do campo de source usado como tempo do evento.
timeFormat	EventTimeFormat	Formato do tempo do evento. Valores válidos: `RFC822`, `RFC850`, `RFC1123`, `RFC3339` e `Unix`.

Status de sincronização

taskSyncStat é do tipo TaskSyncStat e contém os seguintes campos.

Nome	Tipo	Descrição
taskSyncPhase	TaskSyncPhase	Fase de sincronização. Valores válidos: `INIT` para inicialização, `FULL` para sincronização completa e `INCR` para sincronização incremental.
currentSyncPoint	Date	Ponto atual de sincronização no tempo.
errorType	DeliveryErrorType	Tipo de erro. Valores válidos: `OK` quando não há erro, `UNAUTHORIZED` para falha de autorização e `INVALID_OSS_BUCKET` para bucket do OSS inválido.
detail	String	Detalhes sobre o status de sincronização ou o erro.