TopMind Vertica Connector Wrapper
Project description
Customized vertica connector
The Python Wrapper to vertica_python lib for reconnectiong across server nodes
Usage
pip3 install vertica-connector-talenttech
import os
import json
from vconnector.vertica_connector import VerticaConnector
user = "test_user",
password = "test_password"
database = "test_database"
vertica_configs = json.loads(os.getenv("VERTICA_CONFIGS"))
with VerticaConnector(user=user,
password=password,
database=database,
vertica_configs=vertica_configs) as v_connector:
cur = v_connector.cnx.cursor()
sql = "SELECT 1"
cur.execute(sql)
VERTICA_CONFIGS variable structure
{"host": <VERTICA_HOST>,
"port": <VERTICA_PORT>,
"backup_server_node": [<SERVER_NODE_1>, <SERVER_NODE_2>, <SERVER_NODE_3>}
INSERT TABLE EXAMPLE
with VerticaConnector(
user=os.getenv("VERTICA_USER"),
password=os.getenv("VERTICA_PASSWORD"),
database=os.getenv("DATABASE"),
vertica_configs=json.loads(os.getenv("VERTICA_CONFIGS")),
) as v_connector:
cursor = v_connector.cnx.cursor("dict")
cursor.execute("drop table if exists test_staging.test cascade")
cursor.execute(
"""create table netology_staging.test
(
a int,
b varchar(10),
c long varbinary(1000),
d long varchar default MAPTOSTRING(c)
)"""
)
v_connector.insert(
table_name="test",
schema="test_staging",
data=list(
[
{
"a": 1,
"b": "test2",
"c": '[{"x": 1, "y": 2}, {"x": 1, "y": 2}]',
"d": "fuck",
}
]
),
)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for vertica-connector-talenttech-1.1.7.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 4673a7a949d0f833426a0fb3faaa2e659672455d9ebae678c70e9fe283892868 |
|
MD5 | 2739c78c68f8b1c54d3131fdf8610a3d |
|
BLAKE2b-256 | eb699eba02788e6e7b322febe4362a0de78e030babc72c592a97ffce911c1cff |
Close
Hashes for vertica_connector_talenttech-1.1.7-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 2830a92d1f420e7679d47ff34a17fafaa2e5c7cd07072a058cd48b1675fc8af5 |
|
MD5 | af1b72b70d64cc2aeff12cd8d5a150b3 |
|
BLAKE2b-256 | a5c177ff85c2b961b13f9d561bab564a0d5d588c109ebce36d9d4b948c8bdbf8 |