List
List all PXF datasources
- TypeScript
- Python
import { cloudApi, serviceClients, Session } from "@yandex-cloud/nodejs-sdk";
const ListPXFDatasourcesRequest =
cloudApi.mdb.greenplum_pxf_service.ListPXFDatasourcesRequest;
(async () => {
const authToken = process.env["YC_OAUTH_TOKEN"];
const session = new Session({ oauthToken: authToken });
const client = session.client(serviceClients.PXFDatasourceServiceClient);
const result = await client.list(
ListPXFDatasourcesRequest.fromPartial({
clusterId: "clusterId",
})
);
console.log(result);
})();
import os
import grpc
import yandexcloud
from yandex.cloud.mdb.greenplum.v1.pxf_service_pb2 import ListPXFDatasourcesRequest
from yandex.cloud.mdb.greenplum.v1.pxf_service_pb2_grpc import PXFDatasourceServiceStub
token = os.getenv("YC_OAUTH_TOKEN")
sdk = yandexcloud.SDK(token=token)
service = sdk.client(PXFDatasourceServiceStub)
response = service.List(ListPXFDatasourcesRequest(cluster_id="clusterId"))
print(response)
ListPXFDatasourcesRequest
clusterId
: string
ListPXFDatasourcesResponse
datasources
: PXFDatasource
PXFDatasource
name
: string
Data source name.
One of settings
s3
: PXFDatasourceS3Settings of an external S3 data source.
jdbc
: PXFDatasourceJDBCSettings of an external JDBC data source.
hdfs
: PXFDatasourceHDFSSettings of an external HDFS data source.
hive
: PXFDatasourceHiveSettings of an external Hive data source.
PXFDatasourceS3
accessKey
: string
Public key to access S3 storage.
secretKey
: string
Secret key to access S3 storage.
fastUpload
: google.protobuf.BoolValue
Manages a fast upload of big files to S3 storage. In case of the false
value, the PXF generates files on disk before sending them to the S3 storage. In case of the true
value, the PXF generates files in RAM (the PXF writes to disc only if there is not enough RAM).
The fast upload is enabled by default.
endpoint
: string
S3 storage address. The default value is storage.yandexcloud.net
used for Yandex Object Storage.
PXFDatasourceJDBC
driver
: string
JDBC driver class in Java. The possible values are the following:
com.simba.athena.jdbc.Driver
com.clickhouse.jdbc.ClickHouseDriver
com.ibm.as400.access.AS400JDBCDriver
com.microsoft.sqlserver.jdbc.SQLServerDriver
com.mysql.cj.jdbc.Driver
org.postgresql.Driver
oracle.jdbc.driver.OracleDriver
net.snowflake.client.jdbc.SnowflakeDriver
io.trino.jdbc.TrinoDriver
url
: string
URL that the JDBC driver uses to connect to the database. Examples:
jdbc:mysql://mysqlhost:3306/testdb
: Local MySQL DB.jdbc:postgresql://c-<cluster_id>.rw.mdb.yandexcloud.net:6432/db1
: Managed Service for PostgreSQL cluster. The address contains the special FQDN of the cluster's master.jdbc:oracle:thin:@host.example:1521:orcl
: Oracle DB.
user
: string
Username of the DB owner.
password
: string
Password of the DB owner.
statementBatchSize
: google.protobuf.Int64Value
Number of rows to read in an external table, in a batch.
The default value is 100
.
statementFetchSize
: google.protobuf.Int64Value
Number of rows to fetch (buffer) when reading from an external table.
The default value is 1000
.
statementQueryTimeout
: google.protobuf.Int64Value
Amount of time (in seconds) the JDBC driver waits for a statement to run. This timeout applies to statements created for both read and write operations.
The default value is 60
.
poolEnabled
: google.protobuf.BoolValue
Determines whether JDBC connection pooling is used in a server configuration. By default, it is used.
poolMaximumSize
: google.protobuf.Int64Value
Maximum number of connections to the DB backend.
The default value is 5
.
poolConnectionTimeout
: google.protobuf.Int64Value
Maximum time, in milliseconds, to wait for a connection from the pool.
The default value is 30000
.
poolIdleTimeout
: google.protobuf.Int64Value
Maximum amount of time, in milliseconds, after which an inactive connection is considered idle.
The default value is 30000
.
poolMinimumIdle
: google.protobuf.Int64Value
Minimum number of idle connections maintained in the connection pool.
The default value is 0
.
PXFDatasourceHDFS
core
: PXFDatasourceCore
Settings of the file system and security rules.
kerberos
: PXFDatasourceKerberos
Settings of the Kerberos network authentication protocol.
userImpersonation
: google.protobuf.BoolValue
Enables authentication on behalf of the Greenplum® user when connecting to the remote file storage or DBMS.
The authentication is disabled by default.
username
: string
Login username for the remote file storage or DBMS if authentication on behalf of the Greenplum® user is enabled.
saslConnectionRetries
: google.protobuf.Int64Value
Maximum number of times that PXF retries a SASL connection request after a refused connection returns a GSS initiate failed
error.
The default value is 5
.
zkHosts
: string
ZooKeeper server hosts.
Specify values in the <address>:<port>
format.
dfs
: PXFDatasourceHDFSDfs
Settings of the distributed file system.
yarn
: PXFDatasourceHDFSYarn
Settings of the ResourceManager service that is responsible for tracking resources in a cluster and scheduling applications (e.g., MapReduce jobs).
PXFDatasourceHive
core
: PXFDatasourceCore
Settings of the file system and security rules.
kerberos
: PXFDatasourceKerberos
Settings of the Kerberos network authentication protocol.
userImpersonation
: google.protobuf.BoolValue
Enables authentication on behalf of the Greenplum® user when connecting to the remote file storage or DBMS.
The authentication is disabled by default.
username
: string
Login username for the remote file storage or DBMS if authentication on behalf of the Greenplum® user is enabled.
saslConnectionRetries
: google.protobuf.Int64Value
Maximum number of times that PXF retries a SASL connection request after a refused connection returns a GSS initiate failed
error.
The default value is 5
.
zkHosts
: string
ZooKeeper server hosts.
Specify values in the <address>:<port>
format.
ppd
: google.protobuf.BoolValue
Specifies if predicate pushdown is enabled for queries on external tables.
The predicate pushdown is enabled by default.
metastoreUris
: string
List of URIs separated by commas. To request metadata, the remote DBMS connects to Metastore by one of these URIs.
metastoreKerberosPrincipal
: string
Service principal for the Metastore Thrift server.
authKerberosPrincipal
: string
Kerberos server principal.
PXFDatasourceCore
defaultFs
: string
URI whose scheme and authority determine the file system implementation.
securityAuthToLocal
: string
Rules for mapping Kerberos principals to operating system user accounts.
PXFDatasourceKerberos
enable
: google.protobuf.BoolValue
Determines whether the Kerberos authentication server is used. By default, it is not used.
primary
: string
Host of the primary KDC server (Key Distribution Center).
realm
: string
Kerberos realm for a Greenplum® DB.
kdcServers
: string
KDC server hosts.
adminServer
: string
Administration server host. Usually, this is the primary Kerberos server.
defaultDomain
: string
Domain that is used for the host name extension. Applicable when Kerberos 4 service members become Kerberos 5 service members (for example, when rcmd.hostname is replaced with host/hostname.domain).
keytabBase64
: string
Base64 encoded contents of the keytab file.
PXFDatasourceHDFSDfs
haAutomaticFailoverEnabled
: google.protobuf.BoolValue
Determines whether automatic failover is enabled for the high availability of the file system.
The automatic failover is enabled by default.
blockAccessTokenEnabled
: google.protobuf.BoolValue
If true
, access tokens are used as capabilities for accessing datanodes. If false
, no access tokens are checked on accessing datanodes.
The check of access tokens is enabled by default.
useDatanodeHostname
: google.protobuf.BoolValue
Determines whether the datanode hostname is used when connecting to datanodes.
namenodes
: PXFDatasourceHDFSDfsNamenode
List of HDFS service logical names.
Specify them separated by commas. The names can be arbitrary.
nameservices
: string
Corresponds well-known HDFS client setting "dfs.nameservices" for this datasource
PXFDatasourceHDFSYarn
resourcemanagerHaEnabled
: google.protobuf.BoolValue
Determines whether high availability is enabled for YARN's ResourceManager services.
The high availability is enabled by default.
resourcemanagerHaAutoFailoverEnabled
: google.protobuf.BoolValue
Determines whether another ResourceManager should automatically become active when the active ResourceManager has failed and does not respond.
The switch of ResourceManagers is enabled by default if the high availability is enabled.
resourcemanagerHaAutoFailoverEmbedded
: google.protobuf.BoolValue
Determines whether the embedded ActiveStandbyElector method should be used for the election of the active ResourceManager. If the current active ResourceManager has failed and does not respond, the ActiveStandbyElector method makes another ResourceManager active which then takes over.
resourcemanagerClusterId
: string
Cluster ID. Specify it, so the ResourceManager service does not become active for a different cluster.
haRm
: PXFDatasourceHDFSYarnHaRm
Highly available ResourceManager service.