Elasticsearch:Configure a transmissão de dados pela rede pública com o NAT Gateway

Etapa 1: Abrir a configuração do NAT gateway

1. Acesse a página Clusters Logstash no console do Alibaba Cloud Elasticsearch.

2. Na barra de navegação superior, selecione a região do cluster.

3. Na página Logstash Clusters, localize o cluster e clique em no respectivo ID.

4. No painel de navegação à esquerda, clique em Network and Security.

5. Na seção Network Settings, clique em Configure NAT Gateway.

Etapa 2: Crie um NAT gateway de Internet

Na página Internet NAT Gateway, clique em Create Internet NAT Gateway. Selecione a região e a VPC do cluster Logstash.

Para obter descrições detalhadas dos parâmetros, consulte Etapa 1: Crie um NAT gateway de Internet. Para uma visão geral das configurações do NAT gateway, consulte Crie e gerencie NAT gateways de Internet.

Etapa 3: Associar um EIP ao NAT gateway

1. Na página Internet NAT Gateway, localize o NAT gateway e escolha More > Associate EIP na coluna Actions.

2. Na caixa de diálogo Associate EIP, selecione Select Existing EIP e escolha um EIP disponível. Se não houver EIPs disponíveis, selecione Purchase and Associate EIP e clique em OK.

3. Clique em OK.

Etapa 4: Crie uma entrada DNAT

As entradas DNAT permitem que serviços na Internet enviem dados ao cluster Logstash.

1. Na página Internet NAT Gateway, localize o NAT gateway e clique em Configure DNAT na coluna Actions.

2. Clique em na aba DNAT Management.

3. Na seção DNAT Entry List, clique em Create DNAT Entry.

4. Configure os seguintes parâmetros:

   Parâmetro	Descrição
   Select EIP	Selecione um endereço IP público disponível. Não é possível reutilizar aqui um EIP já usado em uma entrada SNAT.
   Select Private IP Address	Escolha Manual Input e insira o endereço IP de um nó do cluster Logstash. Para localizar os endereços IP dos nós, acesse a página Basic Information do cluster. Consulte Visualize as informações básicas de um cluster.
   Port Settings	Defina um método de mapeamento DNAT: Any Port para mapeamento de endereço IP (todas as solicitações ao IP público são encaminhadas ao cluster) ou Custom Port para mapeamento de porta (as solicitações são encaminhadas com base em protocolos e portas específicos). Se selecionar Custom Port, configure também Public Port, Private Port e Protocol.
   Entry Name	Insira um nome para a entrada DNAT. O nome deve ter de 2 a 128 caracteres, começar com uma letra e pode conter letras, dígitos, sublinhados (_) e hifens (-).

5. Clique em OK.

Etapa 5: Crie uma entrada SNAT

As entradas SNAT permitem que o cluster Logstash acesse a Internet.

1. Na página Internet NAT Gateway, localize o NAT gateway e clique em Configure SNAT na coluna Actions.

2. Clique em na aba SNAT Management.

3. Na seção SNAT Entry List, clique em Create SNAT Entry.

4. Em SNAT Entry, selecione Specify vSwitch e configure os seguintes parâmetros:

   Parâmetro	Descrição
   Select vSwitch	Selecione o vSwitch na VPC do cluster Logstash. Assim, todas as instâncias do Elastic Compute Service (ECS) nesse vSwitch poderão acessar a Internet por meio desta entrada SNAT.
   Select EIP	Escolha o endereço IP público para acesso à Internet. Para criar um pool de endereços IP SNAT, selecione vários EIPs. Se selecionar múltiplos EIPs, todos devem estar associados ao mesmo plano de largura de banda de EIP. Consulte Associar e desassociar EIPs de instâncias de Internet Shared Bandwidth.

5. Clique em OK.

Para a lista completa de parâmetros SNAT, consulte Crie e gerencie entradas SNAT.

Etapa 6: Configure o pipeline do Logstash

Retorne à página Basic Information do cluster Logstash no console do Elasticsearch e configure um pipeline para transmitir dados pela Internet. Consulte Usar arquivos de configuração para gerenciar pipelines.

O exemplo abaixo usa Beats como entrada e um cluster Elasticsearch como saída. O servidor Beats está na mesma VPC do cluster Logstash, enquanto o cluster Elasticsearch está em uma VPC diferente. Portanto, é necessária uma entrada SNAT para que o Logstash alcance o cluster Elasticsearch pela Internet.

input {
    beats {
        port => 8000
        host => "118.11.xx.xx"
    }
}
filter {

}
output {
    elasticsearch {
        hosts => ["http://es-cn-o40xxxxxxxxxx****.elasticsearch.aliyuncs.com:9200"]
        index => "logstash_test_1"
        password => "es_password"
        user => "elastic"
    }
    file_extend {
        path => "/ssd/1/ls-cn-v0h1kzca****/logstash/logs/debug/test"
    }
}