Clickhouse 和 RabbitMQ 的连接问题

Question

我是 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 的建议吗？

Answer 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

Clickhouse 和 RabbitMQ 的连接问题

Connection problem with Clickhouse and RabbitMQ

rabbitmq

clickhouse