Установка ADB to ADB Connector
Для установки ADB to ADB Connector выполните следующие шаги:
-
Убедитесь, что сервис ADB to ADB установлен в кластере ADB. Информацию о добавлении сервисов в кластер можно получить в статье Добавление сервисов.
ВАЖНОСервис ADB to ADB необходимо установить в обоих кластерах ADB, между которыми планируется передавать данные.
-
Подключитесь к базе данных через psql (или иную клиентскую программу):
$ psql adb -
Убедитесь, что расширения
adb_fdwиgp_parallel_retrieve_cursorуспешно добавлены. Для этого можно использовать команду psql\dx:\dxРезультат содержит расширения
adb_fdwиgp_parallel_retrieve_cursor:List of installed extensions Name | Version | Schema | Description -----------------------------+---------+------------+--------------------------------------------------------------------- adb_fdw | 1.0 | public | foreign-data wrapper for remote ADB servers arenadata_toolkit | 1.0 | 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 diskquota | 2.2 | public | Disk Quota Main Program 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 postgis | 2.5.4 | public | PostGIS geometry, geography, and raster spatial types and functions pxf | 2.0 | public | Extension which allows to access unmanaged data pxf_fdw | 1.0 | public | PXF Foreign Data Wrapper for Greenplum tkh_fdw | 1.0 | public | ClickHouse Foreign Data Wrapper for Greenplum (12 rows) -
Также можно проверить наличие новой обертки внешних данных (foreign data wrapper)
adb_fdw, обратившись к таблице системного каталогаpg_catalog.pg_foreign_data_wrapper:SELECT * FROM pg_catalog.pg_foreign_data_wrapper;Результат:
fdwname | fdwowner | fdwhandler | fdwvalidator | fdwacl | fdwoptions ---------------+----------+------------+--------------+--------+-------------------------------------------------------------------------------------------- dblink_fdw | 10 | 0 | 16507 | | jdbc_pxf_fdw | 10 | 16767 | 16768 | | {protocol=jdbc,"mpp_execute=all segments"} hdfs_pxf_fdw | 10 | 16767 | 16768 | | {protocol=hdfs,"mpp_execute=all segments"} hive_pxf_fdw | 10 | 16767 | 16768 | | {protocol=hive,"mpp_execute=all segments"} hbase_pxf_fdw | 10 | 16767 | 16768 | | {protocol=hbase,"mpp_execute=all segments"} s3_pxf_fdw | 10 | 16767 | 16768 | | {protocol=s3,"mpp_execute=all segments"} gs_pxf_fdw | 10 | 16767 | 16768 | | {protocol=gs,"mpp_execute=all segments"} adl_pxf_fdw | 10 | 16767 | 16768 | | {protocol=adl,"mpp_execute=all segments"} wasbs_pxf_fdw | 10 | 16767 | 16768 | | {protocol=wasbs,"mpp_execute=all segments"} file_pxf_fdw | 10 | 16767 | 16768 | | {protocol=file,"mpp_execute=all segments"} tkh_fdw | 10 | 16817 | 16816 | | {protocol=tkh_clickhouse,"mpp_execute=all segments",format=text} adb_fdw | 10 | 97034 | 97035 | | kadb_fdw | 10 | 16826 | 16828 | | {"mpp_execute=all segments",k_initial_offset=0,k_automatic_offsets=true,k_latency_ms=2000} (13 rows)