Интеграция MySQL с ClickHouse
Эта страница описывает использование движка таблиц MySQL для чтения из таблицы MySQL.
Подключение ClickHouse к MySQL с использованием движка таблиц MySQL
Движок таблиц MySQL позволяет подключить ClickHouse к MySQL. SELECT и INSERT операторы могут выполняться как в ClickHouse, так и в таблице MySQL. В этой статье показаны основные методы использования движка таблиц MySQL.
1. Настройка MySQL
- Создайте базу данных в MySQL:
- Создайте таблицу:
- Вставьте образцы строк:
- Создайте пользователя для подключения из ClickHouse:
- Предоставьте привилегии по мере необходимости. (Для демонстрационных целей пользователю
mysql_clickhouseпредоставляются административные привилегии.)
Если вы используете эту функцию в ClickHouse Cloud, вам может понадобиться разрешить IP-адреса ClickHouse Cloud для доступа к вашему экземпляру MySQL. Проверьте документацию ClickHouse Cloud Endpoints API для получения информации о выходящем трафике.
2. Определите таблицу в ClickHouse
- Теперь давайте создадим таблицу ClickHouse, которая использует движок таблиц
MySQL:
Минимальные параметры:
| parameter | Description | example |
|---|---|---|
| host | hostname или IP | mysql-host.domain.com |
| database | имя базы данных MySQL | db1 |
| table | имя таблицы MySQL | table1 |
| user | имя пользователя для подключения к mysql | mysql_clickhouse |
| password | пароль для подключения к mysql | Password123! |
Просмотрите страницу документации MySQL table engine для полного списка параметров.
3. Протестируйте интеграцию
- В MySQL вставьте образец строки:
- Обратите внимание, что существующие строки из таблицы MySQL находятся в таблице ClickHouse вместе с новой строкой, которую вы только что добавили:
Вы должны увидеть 4 строки:
- Давайте добавим строку в таблицу ClickHouse:
- Обратите внимание, что новая строка появилась в MySQL:
Вы должны увидеть новую строку:
Резюме
Движок таблиц MySQL позволяет подключать ClickHouse к MySQL для обмена данными в обе стороны. Для получения дополнительных сведений не забудьте ознакомиться с документацией на странице MySQL table engine.