Clickhouse 和 RabbitMQ 的连接问题

Posted 2023-03-25

【中文标题】Clickhouse 和 RabbitMQ 的连接问题

【英文标题】：Connection problem with Clickhouse and RabbitMQ

【发布时间】：2021-06-22 03:42:11

【问题描述】：

我是Clickhouse 和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 有什么建议吗？

【参考方案1】：

Rabbit MQ credentials 应该在配置文件中定义：

打开存在或创建一个新的自定义配置文件rabbitmq.xml

sudo nano /etc/clickhouse-server/config.d/rabbitmq.xml

添加此配置并保存

<yandex>
    <rabbitmq>
        <username>your_rabbitmq_username</username>
        <password>your_rabbitmq_password</password>
    </rabbitmq>
</yandex>

重启服务

sudo service clickhouse-server restart