MicroStrategy ONE
Configurar alto rendimento ou arquitetura avançada
Este tópico explica como configurar a arquitetura de alto rendimento usando um cluster de nós Kafka (servidores de telemetria). Um armazenamento de telemetria (Platform Analytics) só pode consumir dados de um único nó Kafka ou de um único cluster Kakfa.
Todos os nós Kafka devem estar em cluster e vários clusters Kafka não são suportados.
Comece com os seguintes tópicos:
2. Configurar servidor de telemetria
3. Reinicie os serviços necessários
4. Configurar consumidor do Platform Analytics
1. Instalar componentes
Comece instalando componentes nos ambientes correspondentes.
-
Escolha os seguintes componentes para as máquinas 1, 2 e 3 no assistente de instalação:
-
MicroStrategy Inteligência
-
MicroStrategy Telemetry Server
-
Escolher Crie um cluster... ao criar um ambiente clusterizado para Telemetria e fornecer os outros nós ou endereços de máquinas onde você instalou ou irá instalar a Telemetria. Repita isso para as máquinas 1, 2 e 3.
-
-
Escolha os seguintes componentes para as máquinas 4 e 5 no assistente de instalação:
-
MicroStrategy Inteligência
-
MicroStrategy Telemetry Server
-
- Após a instalação, desligue MicroStrategy Servidor de telemetria (serviços Kafka e Zookeeper).
-
Escolha os seguintes componentes para a máquina 6 no assistente de instalação:
-
Platform Analytics
-
Durante a instalação dos componentes, você deve inserir informações de conexão do repositório (máquina 7).
-
-
Instale o Platform Analytics Repository na máquina 7. Você pode escolher um pronto para uso MicroStrategy Repositório ou opte por sua própria instância de Servidor de banco de dados PostgreSQL, fornecido pelo seuorganização.
-
Para implantações do Windows, continue com Modificações específicas do Windows para criar o serviço Platform Analytics, caso contrário vá para 2. Configurar servidor de telemetria para implantações Linux.
Modificações específicas do Windows para criar o serviço Platform Analytics
Em máquinas Windows, você deve recriar o serviço Platform Analytics para evitar que o serviço fique inativo.
-
Vá para Serviços.
-
Parar MicroStrategy Consumidor de análise de plataforma.
-
Parar MicroStrategy Cache na memória do Platform Analytics.
-
-
Exclua o MicroStrategy Serviço de consumidor de análise de plataforma.
-
Inicie um prompt de comando do Windows com privilégios administrativos.
-
Execute o seguinte comando:
Copiarsc delete MSTR_PlatformAnalyticsConsumer
-
Fechar serviços.
-
-
Recrie o serviço Platform Analytics Consumer.
-
Navegue até o diretório Platform Analytics.
-
Abrir
MSTR_PlatformAnalyticsConsumer.config
para edição. -
Excluir
--DependesOn =Redis
para remover os serviços dependentes (Kafka e Zookeeper).
-
-
Inicie um prompt de comando do Windows com privilégios administrativos.
-
Navegue até o diretório Platform Analytics.
-
Execute o seguinte comando:
CopiarPlatformAnalyticsConsumer.exe install MSTR_PlatformAnalyticsConsumer --Config PlatformAnalyticsConsumer_config.txt
-
-
Vá para Serviços.
-
Começar MicroStrategy Consumidor de análise de plataforma.
-
Atualize o Service Manager, se necessário.
-
2. Configurar servidor de telemetria
Execute as seguintes etapas abaixo para todos Nós do servidor de telemetria. Este exemplo usa máquinas 1, 2 e 3.
Editar server.properties
-
Abrir
server.properties
para edição.Localização das janelas:
C:\Program Files (x86)\MicroStrategy\Messaging Services\Kafka\kafka_x.x.xx\config
Localização do Linux:
/opt/MicroStrategy/MessagingServices/Kafka/kafka_x.x.x./config
-
Sob
##### Server Basics ####
, forneça um ID do agente exclusivo para cada máquina do servidor Telemetry na ordem preferencial de failover do nó.Neste exemplo:
Máquina 1:
broker.id=1
Máquina 2:broker.id=2
Máquina 3:broker.id=3
Copiar# Set the broker id to a unique value for each node.
# Do not change it on the machine configured during single node set up, i.e. your main node. It should be left at the default value and referred to by the other nodes.
# For example,
broker.id=1 -
Sob
##### Internal Topic Settings ####
, defina os deslocamentos e os fatores de estado da transação para a quantidade de nós no cluster. Neste exemplo, isso é 3.Copiar# offsets.topic.replication.factor= set to the number of nodes in your cluster
# transaction.state.log.replication.factor= set to the number of nodes in your cluster
# For example,
offsets.topic.replication.factor=3
transaction.state.log.replication.factor=3 -
Sob
##### Zookeeper #####
, adicione todos os endereços IP ou FQDNs do nó do servidor de telemetria para ozookeeper.connect
parâmetro. A ordem dos nós precisa corresponder ao parâmetro de ID do corretor na etapa 2.Copiar# Set zookeeper.connect= to a comma separated list of <IP address:2181> for all nodes in the cluster.
# For example,
zookeeper.connect=10.27.18.73:2181,10.27.18.224:2181,10.27.36.168:2181
Editar zookeeper.properties
-
Abrir
zookeeper.properties
para edição.Localização das janelas:
C:\Program Files (x86)\MicroStrategy\Messaging Services\Kafka\kafka_x.x.xx\config
Localização do Linux:
/opt/MicroStrategy/MessagingServices/Kafka/kafka_x.x.x./config
-
Adicione novas linhas no final do arquivo com
server.node_id=ip:2888:3888
. Neste exemplo, existem três novas linhas para cada nó.Copiar# To allow Zookeeper to work with the other nodes in your cluster, add the following properties to the end of the zookeeper.properties file.
# initLimit=5
# syncLimit=2
# server.X= <IP address of the node>:2888:3888
# When adding this property, replace X above with the broker.id for the node being referenced. A separate entry must be made for each node in the cluster.
# For example,
initLimit=5
syncLimit=2
server.0=10.27.18.73:2888:3888
server.1=10.27.18.224:2888:3888
server.2=10.27.36.168:2888:3888
Editar meuid
-
Abrir
myid
para edição. Se este arquivo não existir, você deve criar um.Localização das janelas:
C:\Program Files (x86)\MicroStrategy\Messaging Services\tmp\zookeeper
Localização do Linux:
/opt/MicroStrategy/MessagingServices/tmp/zookeeper
-
Confirme que o
myid
arquivo faz não tem uma extensão oculta. No Explorador de Arquivos, vá para Visualizar > Mostrar > Extensões de nome de arquivo para mostrar extensões. Se o seu arquivo tiver uma extensão, remova-a. -
Certifique-se de que
broker.id
para cada nó corresponde os valores que você definiuserver.properties
.Copiar# Make sure the broker.id is the same as it appears in server.properties.
# For example,
broker.id=1
3. Reinicie os serviços necessários
Depois de atualizar as configurações do Kafka e do Zookeeper em todos os nós do cluster, deve-se reiniciar os serviços, incluindo o Intelligence Server.
Ao reiniciar os serviços, é importante observar que todas as alterações nos arquivos de configuração devem ser concluídas. Por exemplo, se você estiver adicionando dois nós Kafka adicionais e já tiver um nó existente, a instalação e a configuração deverão ser concluídas em todos os três nós antes de reiniciar qualquer um dos serviços.
Além disso, alguns serviços dependem uns dos outros, portanto, os serviços devem ser iniciados na ordem fornecida abaixo. Não iniciar nesta ordem pode causar inconsistências nos serviços.
-
Inicie o Zookeeper e o Kafka no nó principal antes de iniciar outros nós.
-
Inicie o Zookeeper nos nós restantes.
-
Inicie o Kafka nos nós restantes.
4. Configurar consumidor do Platform Analytics
Execute as etapas a seguir no nó em que você está executando o Platform Analytics Consumer. Neste exemplo, essa é a máquina 6.
-
Abrir
PAConsumerConfig.yaml
para edição.Localização das janelas:
C:\Program Files (x86)\MicroStrategy\Platform Analytics\conf
Localização do Linux:
/opt/MicroStrategy/Platform Analytics/conf
-
Adicione todos os endereços IP do nó de telemetria ao arquivo usando o seguinte formato:
zookeeperConnection:IP1:port,IP2:port,IP3:port
bootstrap.servers: IP1:port,IP2:port,IP3:port
Copiar# Set kafkaTopicNumberOfReplicas: number of nodes in cluster
# Set zookeeperConnection: <ipAddress:2181> for all nodes in cluster
# Set bootstrap.servers: <ipAddress:9092> for all nodes in cluster
# For example,
kafkaTopicNumberOfReplicas: 3
zooKeeperConnection: 10.27.18.73:2181,10.27.18.224:2181
bootstrap.servers: 10.27.18.73:9092,10.27.18.224:9092 -
Certifique-se de que o
kafkaTopicNumberOfReplicas
parâmetro corresponde ao número de nós do servidor de telemetria. Neste exemplo, isso seria 3. -
Reinicie os seguintes serviços:
-
MicroStrategy Platform Analytics Consumer
-
MicroStrategy Cache na memória do Platform Analytics
-