addArgument(
'indices',
InputArgument::IS_ARRAY | InputArgument::REQUIRED,
'Elasticsearch indices name to update, separated by spaces'
);
}
public function execute(InputInterface $input, OutputInterface $output): int
{
$sourceAliasNames = $input->getArgument('indices');
foreach ($sourceAliasNames as $sourceAliasName) {
$destinationAliasName = sprintf('%s_alias_%s', $sourceAliasName, Uuid::uuid4());
$destinationIndexName = sprintf('%s_%s', $sourceAliasName, Uuid::uuid4());
$output->writeln("Recapitulation of the operation:
- Source alias: $sourceAliasName
- Destination alias: $destinationAliasName
- Destination index: $destinationIndexName
");
$question = new ConfirmationQuestion("Are you sure to update $sourceAliasName index? [Y/n]", true);
if (!$this->getHelper('question')->ask($input, $output, $question)) {
return Command::SUCCESS;
}
try {
$this->updateIndexWithoutDowntime(
$sourceAliasName,
$destinationAliasName,
$destinationIndexName
);
} catch (\Exception $e) {
$errOutput = $output instanceof ConsoleOutputInterface ? $output->getErrorOutput() : $output;
$errOutput->writeln(sprintf(
"Index %s have not been updated du to the following error: \n%s",
$sourceAliasName,
$e->getMessage()
));
return Command::FAILURE;
}
$output->writeln("Index $sourceAliasName have been updated");
}
return Command::SUCCESS;
}
private function updateIndexWithoutDowntime(
string $sourceAliasName,
string $destinationAliasName,
string $destinationIndexName,
): void {
$sourceIndexConfiguration = $this->indexUpdaterClient->getIndexConfiguration($sourceAliasName);
$sourceIsAnAlias = $this->indexUpdaterClient->isAnAlias($sourceAliasName);
if (!$sourceIsAnAlias && $this->indexUpdaterClient->haveAlias($sourceAliasName)) {
throw new \Exception('Cannot find index with this alias, Please provide the correct index alias.');
}
if (!$sourceIsAnAlias) {
$newSourceAliasName = sprintf('%s_migration_alias', $sourceAliasName);
$this->indexUpdaterClient->createAlias($newSourceAliasName, $sourceAliasName);
$sourceAliasName = $newSourceAliasName;
}
$sourceIndexName = $this->indexUpdaterClient->getIndexNameFromAlias($sourceAliasName);
$this->indexUpdaterClient->createDestinationIndex($destinationIndexName, $destinationAliasName, $sourceIndexConfiguration);
$this->indexUpdaterClient->reindexAllDocuments($sourceAliasName, $destinationAliasName);
$this->indexUpdaterClient->resetIndexSettings($destinationIndexName, $sourceIndexName);
$this->indexUpdaterClient->switchIndexAliasToNewIndex(
$sourceAliasName,
$sourceIndexName,
$destinationAliasName,
$destinationIndexName
);
$this->indexUpdaterClient->reindexDocumentsAfterSwitch($destinationAliasName, $sourceAliasName);
$this->indexUpdaterClient->removeIndex($sourceIndexName);
if (!$sourceIsAnAlias) {
$this->indexUpdaterClient->renameAlias($sourceAliasName, $sourceIndexName, $destinationIndexName);
}
}
}