TopMind Vertica 连接器包装器
项目描述
定制的垂直连接器
vertica_python 库的 Python 包装器，用于跨服务器节点重新连接
用法
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 变量结构
{"host": <VERTICA_HOST>,
"port": <VERTICA_PORT>,
"backup_server_node": [<SERVER_NODE_1>, <SERVER_NODE_2>, <SERVER_NODE_3>}
插入表格示例
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",
}
]
),
)
关
vertica_connector_talenttech -1.2.0-py3-none-any.whl 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | 192258925e0b3fab3eb7f67ffeb79d6d6e6f9fa580e116f54029f698521f269c |
|
| MD5 | 47916f26ef27ec856e84cd8b76da76d1 |
|
| 布莱克2-256 | 49689cb3a4e10b80fb38102d786c6a430912357354b9bc89774142e95043540d |