pip install -i https://mirrors.tencent.com/pypi/simple/ tencentcloud-dlc-connector

import tdlc_connector
import datetime
from tdlc_connector import constants

conn = tdlc_connector.connect(region="<REGION>", 
    secret_id="<SECRET_ID>", 
    secret_key="<SECRET_KEY>",
    token=None,
    endpoint=None,
    catalog=constants.Catalog.DATALAKECATALOG,  
    engine="<ENGINE>",
    engine_type=constants.EngineType.AUTO, 
    result_style=constants.ResultStyles.LIST,
    download=False,
    mode=constants.Mode.LASY,
    database='',
    config={},
    callback=None,
    callback_events=None,
    )

# 基本操作

cursor = conn.cursor()
count = cursor.execute("SELECT 1")
print(cursor.fetchone())                    # 一行のデータを読み取ります
for row in cursor.fetchall():               # 残りの複数行のデータを読み取ります
    print(row)

「{assistant_name}」機能をオンにしますか？

cursor.execute("SELECT * FROM dummy WHERE date < %s", datetime.datetime.now())           
cursor.execute("SELECT * FROM dummy WHERE status in %s", (('SUCCESS', 'INIT', 'FAIL'),))
cursor.execute("SELECT * FROM dummy WHERE date < %(date)s AND status = %(status)s", {'date': datetime.datetime.now(), 'status': 'SUCCESS'})

BULK方式を使用します

cursor.executemany("INSERT INTO dummy VALUES(%s, %s)", [('張三', 18), ('李四', 20)])

import tdlc_connector
import datetime
from tdlc_connector import constants


def tdlc_connector_callback(statement_id, state):
    '''
    parmas: statement_id タスクID
    params: state タスクの状態、列挙値はconstants.TaskStatusを参照
    '''
    print(statement_id, state)


conn = tdlc_connector.connect(region="<REGION>", 
    secret_id="<SECRET_ID>", 
    secret_key="<SECRET_KEY>",
    engine="<ENGINE>",
    engine_type=constants.EngineType.SPARK, 
    result_style=constants.ResultStyles.LIST,
    callback=tdlc_connector_callback,
    callback_events=[constants.CallbackEvent.ON_INIT, constants.CallbackEvent.ON_SUCCESS]
    )

cursor = conn.cursor()
cursor.execute("SELECT 1")
cursor.fetchone()

# コールバック関数は、タスクの初期化時とタスク成功時に呼び出されます


from tdlc_connector import constants

conn = tdlc_connector.connect(region="<REGION>", 
    secret_id="<SECRET_ID>", 
    secret_key="<SECRET_KEY>",
    engine="<ENGINE>",                            # spark ジョブエンジンを選択してください
    result_style=constants.ResultStyles.LIST,
    driver_size=constants.PodSize.SMALL,          # Driver 仕様を選択してください
    executor_size=constants.PodSize.SMALL,        # Executor 仕様を選択してください
    executor_num=1,                               # Executor 数を設定してください
    executor_max_num=1,                           # Executor 最大数を設定してください。{executor_num}と等しくない場合、動的リソース割り当てを開始します
)

from tdlc_connector import constants

conn = tdlc_connector.connect(region="<REGION>", 
    secret_id="<SECRET_ID>", 
    secret_key="<SECRET_KEY>",
    engine="<ENGINE>",                            
    engine_type=constants.EngineType.AUTO      # AUTOに設定するか、このパラメータを渡さずにドライバーに自動推論させることができます
)

from tdlc_connector import constants, formats

formats.FORMAT_STRING_NULL = '\\1'  

conn = tdlc_connector.connect(region="<REGION>", 
    secret_id="<SECRET_ID>", 
    secret_key="<SECRET_KEY>",
    engine="<ENGINE>",
    result_style=constants.ResultStyles.LIST
)