Установка ADB ClickHouse Connector
Для установки ADB ClickHouse Connector выполните следующие шаги:
-
Установите сервисы PXF и ADB ClickHouse Connector в кластере ADB. Информацию о добавлении сервисов в кластер можно получить в статье Добавление сервисов.
-
На мастер-хосте ADB убедитесь, что в конфигурационном файле PXF (/var/lib/pxf/conf/pxf-profiles.xml) присутствует профиль
Tkh_clickhouse:text.<profiles> <profile> <name>Tkh_clickhouse:text</name> <description>Clickhouse</description> <plugins> <accessor>io.arenadata.tkh.pxf.TkhFdwAccessor</accessor> <resolver>io.arenadata.tkh.pxf.TkhResolver</resolver> </plugins> </profile> </profiles>ПРИМЕЧАНИЕДиректория, в которой расположены конфигурационные файлы PXF, определяется переменной окружения
PXF_BASE. Значение переменной по умолчанию — /var/lib/pxf. Значение может быть изменено при использовании опции Use custom PXF_BASE в конфигурации сервиса PXF. -
Убедитесь, что расширения
gptkh,pxf_fdw,tkh_fdwуспешно добавлены. Для этого можно использовать командуpsql\dx:\dxРезультат содержит расширения
gptkh,pxf_fdw,tkh_fdw:List of installed extensions Name | Version | Schema | Description -----------------------------+---------+------------+---------------------------------------------------------------- adb_fdw | 1.0 | public | foreign-data wrapper for remote ADB servers arenadata_toolkit | 1.8 | public | extension is used for manipulation of objects created by adb-bundle dblink | 1.1 | public | connect to other PostgreSQL databases from within a database gp_parallel_retrieve_cursor | 1.0 | pg_catalog | Retrieve results of cursor in parallel gptkh | 0.14 | public | gptkh kadb_fdw | 0.16 | kadb | Kafka-ADB foreign data wrapper plpgsql | 1.0 | pg_catalog | PL/pgSQL procedural language pxf | 2.1 | public | Extension which allows to access unmanaged data pxf_fdw | 1.0 | public | PXF Foreign Data Wrapper for Greengage tkh_fdw | 1.0 | public | ClickHouse Foreign Data Wrapper for Greenplum (10 rows) -
Также можно проверить наличие новой обертки сторонних данных (foreign data wrapper)
tkh_fdw, обратившись к таблице системного каталогаpg_catalog.pg_foreign_data_wrapper:SELECT * FROM pg_catalog.pg_foreign_data_wrapper WHERE fdwname='tkh_fdw';Результат:
fdwname | fdwowner | fdwhandler | fdwvalidator | fdwacl | fdwoptions ---------+----------+------------+--------------+--------+---------------------------------------------------------------- tkh_fdw | 10 | 16880 | 16879 | | {protocol=tkh_clickhouse,"mpp_execute=all segments",format=text} (1 row)