Configura a atualização automática para um fluxo de dados especificado.
Descrição da operação
-
Esta operação se aplica apenas a sistemas de arquivos CPFS.
-
Apenas o CPFS 2.2.0 e versões posteriores suportam fluxos de dados. Você pode visualizar as informações da versão na página de detalhes do sistema de arquivos no console.
-
Você pode adicionar configurações de atualização automática apenas a fluxos de dados que estejam no estado
Running. -
Você pode adicionar até cinco configurações de atualização automática para um único fluxo de dados.
-
A criação de uma configuração de atualização automática geralmente leva de 2 a 5 minutos. Você pode chamar a operação DescribeDataFlows para consultar o status do fluxo de dados.
-
A atualização automática depende do EventBridge para coletar eventos de modificação de objetos do armazenamento OSS de origem. Você deve primeiro ativar o EventBridge.
NotaOs barramentos de eventos e as regras de eventos criados pelo CPFS no EventBridge contêm a descrição
Create for cpfs auto refresh. Não modifique nem exclua esses barramentos de eventos e regras de eventos. Caso contrário, a atualização automática não funcionará corretamente. -
A atualização automática se aplica aos prefixos especificados pelo parâmetro RefreshPath. Quando você configura a atualização automática para um prefixo em um fluxo de dados CPFS, um barramento de eventos é criado no lado do usuário e uma regra de evento é criada para o prefixo do bucket OSS de origem. Quando um objeto no prefixo do bucket OSS de origem é modificado, um evento OSS é gerado no EventBridge e processado pelo fluxo de dados CPFS.
-
Após a configuração da atualização automática (AutoRefresh), se os dados no armazenamento de origem forem alterados, os metadados alterados passarão por sincronização automática para o sistema de arquivos CPFS. Os dados alterados são carregados sob demanda quando você acessa os arquivos, ou você pode iniciar um nó de fluxo de dados para carregar os dados.
-
O intervalo de atualização automática (AutoRefreshInterval) especifica o intervalo de tempo no qual o CPFS verifica se os dados no prefixo do bucket OSS de origem foram atualizados. Se os dados forem atualizados, um nó de atualização automática será iniciado. Se a frequência de eventos de modificação de objetos no bucket OSS de origem exceder a capacidade de processamento do fluxo de dados CPFS, os nós de atualização automática se acumularão, as atualizações de metadados serão atrasadas e o fluxo de dados entrará no estado Misconfigured. Para resolver esse problema, você pode atualizar as especificações do fluxo de dados ou reduzir a frequência de modificações do OSS.
Experimente agora
Testar
Autorização RAM
|
Ação |
Nível de acesso |
Tipo de recurso |
Chave de condição |
Ação dependente |
|
nas:ApplyDataFlowAutoRefresh |
update |
*DataFlow.
|
Nenhuma | Nenhuma |
Parâmetros da solicitação
|
Parâmetro |
Tipo |
Obrigatório |
Descrição |
Exemplo |
| FileSystemId |
string |
Sim |
O ID do sistema de arquivos. |
cpfs-099394bd928c**** |
| DataFlowId |
string |
Sim |
O ID do fluxo de dados. |
df-194433a5be31**** |
| AutoRefreshs |
array<object> |
Sim |
A coleção de configurações de atualização automática. |
|
|
object |
Não |
|||
| RefreshPath |
string |
Sim |
O diretório de atualização automática. O CPFS verifica automaticamente se os dados de origem neste diretório foram atualizados e importa automaticamente os dados atualizados. Limites:
Nota
O diretório já deve existir no CPFS e deve estar localizado em um fileset para o qual o recurso de fluxo de dados esteja ativado. |
/prefix1/prefix2/ |
| AutoRefreshPolicy |
string |
Não |
A política de atualização automática. Esta política determina como as atualizações de dados da origem são importadas para o CPFS após a atualização dos dados de origem. Valores válidos:
Valores válidos:
|
None |
| AutoRefreshInterval |
integer |
Não |
O intervalo de atualização automática. O CPFS verifica se os dados no diretório foram atualizados neste intervalo. Se os dados forem atualizados, uma tarefa de atualização automática será iniciada. Unidade: minutos. Valores válidos: 10 a 525600. Valor padrão: 10. |
10 |
| DryRun |
boolean |
Não |
Especifica se deve ser realizado um dry run na solicitação de criação. Um dry run verifica se os parâmetros são válidos e se os recursos estão disponíveis, sem realmente criar a instância ou gerar cobranças. Valores válidos:
|
false |
| ClientToken |
string |
Não |
O token de cliente usado para garantir a idempotência da solicitação. Você pode gerar o token em seu cliente e garantir que o token seja exclusivo em diferentes solicitações. O token de cliente pode conter apenas caracteres ASCII e não pode exceder 64 caracteres de comprimento. Para obter mais informações, consulte Como garantir a idempotência. Nota
Se você não especificar este parâmetro, o sistema usará automaticamente o RequestId da solicitação de API como o token de cliente. O RequestId de cada solicitação de API pode ser diferente. |
123e4567-e89b-12d3-a456-42665544**** |
Elementos de resposta
|
Elemento |
Tipo |
Descrição |
Exemplo |
|
object |
|||
| RequestId |
string |
O ID da solicitação. |
98696EF0-1607-4E9D-B01D-F20930B6**** |
Exemplos
Resposta de sucesso
JSON formato
{
"RequestId": "98696EF0-1607-4E9D-B01D-F20930B6****"
}
Códigos de erro
|
Código de status HTTP |
Código de erro |
Mensagem de erro |
Descrição |
|---|---|---|---|
| 400 | IllegalCharacters | The parameter contains illegal characters. | O parâmetro especificado é inválido. |
| 400 | MissingFileSystemId | FileSystemId is mandatory for this action. | O parâmetro FileSystemId não foi especificado. |
| 400 | MissingDataFlowId | DataFlowId is mandatory for this action. | O parâmetro DataFlowId não foi especificado. |
| 403 | OperationDenied.InvalidState | The operation is not permitted when the status is processing. | Esta operação não é permitida enquanto o recurso estiver no estado de processamento. |
| 403 | InvalidFileSystem.AlreadyExisted | The specified file system already exists. | O sistema de arquivos especificado já existe. Você pode chamar a operação DescribeFileSystems e especificar o ID do sistema de arquivos para visualizar as informações relacionadas. |
| 403 | OperationDenied.DependencyViolation | The operation is denied due to dependancy violation. | As condições para a execução desta operação não foram atendidas. |
| 403 | OperationDenied.NestedDir | The operation is denied due to nested directory. | Falha ao criar a configuração de atualização automática porque existem diretórios aninhados. |
| 403 | OperationDenied.ConflictOperation | The operation is denied due to a conflict with an ongoing operation. | O fluxo de dados não pode ser criado devido a conflitos com as operações atuais do sistema de arquivos. |
| 403 | OperationDenied.DataFlowNotSupported | The operation is not supported. | O sistema de arquivos não suporta fluxo de dados. |
| 404 | InvalidFileSystem.NotFound | The specified file system does not exist. | O sistema de arquivos especificado não existe. |
| 404 | InvalidDataFlow.NotFound | The specified data flow does not exist. | O fluxo de dados especificado não existe. |
| 404 | InvalidRefreshPath.InvalidParameter | Refresh path is invalid. | O caminho do diretório de atualização automática especificado é inválido. |
| 404 | InvalidRefreshPath.NotFound | Refresh path does not exist. | O diretório de atualização automática especificado não existe. |
| 404 | InvalidRefreshPolicy.InvalidParameter | Refresh policy is invalid. | A política de atualização automática é inválida. |
| 404 | InvalidRefreshInterval.OutOfBounds | Refresh interval is out of bounds. | O RefreshInterval especificado não está dentro do intervalo válido. |
| 404 | InvalidRefreshPath.AlreadyExist | The refresh path already exists. | O diretório de atualização automática especificado já existe. |
| 404 | InvalidRefreshPath.TooManyPaths | The number of refresh paths exceeds the limit. | O número de diretórios de atualização automática consultados excede o limite. |
Consulte Códigos de Erro para uma lista completa.
Notas de versão
Consulte Notas de Versão para uma lista completa.