时间戳

首页 > 解决方案 > Clickhouse 和 RabbitMQ 的连接问题

rabbitmq - Clickhouse 和 RabbitMQ 的连接问题

问题描述

我是Clickhouseand的新手RabbitMQ。当我尝试使用以下脚本记录数据时RabbitMQ，Clickhouse它不起作用。

CREATE TABLE Station (
    Station varchar(2000)
  ) ENGINE = RabbitMQ SETTINGS rabbitmq_host_port = '<IP>:5672',
                            rabbitmq_exchange_name = 'Clickhouse',
                            rabbitmq_exchange_type = 'direct',
                            rabbitmq_routing_key_list = 'Station',
                            rabbitmq_format = 'CSV',
                            rabbitmq_num_consumers = 1;

并给出以下错误消息。

SQL Error [115]: ClickHouse exception, code: 115, host: <IP>, port: 8123; Code: 115, e.displayText() = DB::Exception: Unknown setting rabbitmq_username: for storage RabbitMQ (version 21.4.3.21 (official build))

设置 rabbitmq_username 有什么建议吗？

标签： rabbitmqclickhouse

解决方案

Rabbit MQ 凭证应在配置文件中定义：

  1. 打开存在或创建一个新的自定义配置文件rabbitmq.xml
sudo nano /etc/clickhouse-server/config.d/rabbitmq.xml
  1. 添加此配置并保存
<yandex>
    <rabbitmq>
        <username>your_rabbitmq_username</username>
        <password>your_rabbitmq_password</password>
    </rabbitmq>
</yandex>
  1. 重启服务
sudo service clickhouse-server restart

推荐阅读