Интеграция Azure Synapse с ClickHouse

Поддерживается в ClickHouse

Azure Synapse — это интегрированный сервис аналитики, который объединяет большие данные, data science и хранилища данных, обеспечивая быстрый анализ данных в большом масштабе. В Synapse пулы Spark предоставляют масштабируемые кластеры Apache Spark по запросу, позволяя выполнять сложные преобразования данных, задачи машинного обучения и интеграции с внешними системами.

В этой статье показано, как использовать коннектор ClickHouse Spark при работе с Apache Spark в Azure Synapse.

Добавьте зависимости коннектора

Azure Synapse поддерживает три уровня управления пакетами:

Пакеты по умолчанию
Уровень пула Spark
Уровень сеанса

Следуйте руководству Manage libraries for Apache Spark pools и добавьте в приложение Spark следующие обязательные зависимости

clickhouse-spark-runtime-{spark_version}_{scala_version}-{connector_version}.jar - официальный репозиторий Maven
clickhouse-jdbc-{java_client_version}-all.jar - официальный репозиторий Maven

Ознакомьтесь с нашей документацией Матрица совместимости коннектора Spark, чтобы понять, какие версии лучше всего подходят для ваших задач.

Добавьте ClickHouse как каталог

Добавить конфигурации Spark в ваш сеанс можно несколькими способами:

Использовать пользовательский файл конфигурации, загружаемый вместе с сеансом
Добавить конфигурации через интерфейс Azure Synapse
Добавить конфигурации в ноутбуке Synapse

Следуйте руководству Manage Apache Spark configuration и добавьте требуемые коннектором конфигурации Spark.

Например, сеанс Spark в ноутбуке можно настроить с помощью следующих параметров:

%%configure -f
{
    "conf": {
        "spark.sql.catalog.clickhouse": "com.clickhouse.spark.ClickHouseCatalog",
        "spark.sql.catalog.clickhouse.host": "<clickhouse host>",
        "spark.sql.catalog.clickhouse.protocol": "https",
        "spark.sql.catalog.clickhouse.http_port": "<port>",
        "spark.sql.catalog.clickhouse.user": "<username>",
        "spark.sql.catalog.clickhouse.password": "password",
        "spark.sql.catalog.clickhouse.database": "default"
    }
}

Убедитесь, что в первой ячейке указано следующее:

Настройка конфигурации Spark через notebook

Дополнительные настройки см. на странице конфигурации ClickHouse Spark.

Проверка настройки

Чтобы убедиться, что зависимости и конфигурации заданы успешно, откройте Spark UI для вашего сеанса и перейдите на вкладку Environment. Там найдите параметры, связанные с ClickHouse: