스크립트 개발 / 커넥터 객체 `DFF.CONN` / 개요

커넥터를 생성한 후 코드에서 DFF.CONN(connector_id, **kwargs)를 호출하여 지정된 커넥터의 작업 객체를 가져올 수 있습니다.

매개변수	유형	필수 / 기본값	설명
`connector_id`	str	필수	커넥터 ID
`**kwargs`	-	-	이번 작업 객체의 일부 구성을 덮어씁니다. 지원 범위는 커넥터 유형에 따라 다릅니다

값이 None 또는 빈 문자열인 선택적 매개변수는 무시됩니다. 선택적 매개변수를 전달하지 않으면 작업 객체는 커넥터에 저장된 구성 또는 코드 기본값을 사용합니다.

예시
@DFF.API('InfluxDB 작업 데모')
def influxdb_demo():
    db = DFF.CONN('demo_influxdb')
    return db.query('SELECT * FROM demo LIMIT 3')

각 커넥터에서 지원하는 선택적 매개변수는 다음과 같습니다.

커넥터 유형	선택적 매개변수	설명
Guance Cloud, TrueWatch	`timeout`	HTTP 요청 제한 시간, 기본 `10`초
DataKit	`source`, `timeout`, `split_size`	Source, 요청 제한 시간 및 배치 분할 크기 덮어쓰기
DataWay	`token`, `timeout`, `split_size`	Token, 요청 제한 시간 및 배치 분할 크기 덮어쓰기
DataFlux Func Sidecar	`timeout`	HTTP 요청 제한 시간, 기본 `10`초
InfluxDB	`database`	기본 데이터베이스 덮어쓰기
MySQL	`database`	기본 데이터베이스 덮어쓰기
Redis	`database`, `client_name`	데이터베이스 번호 및 Redis 클라이언트 이름 덮어쓰기
Memcached	-	선택적 매개변수 없음
ClickHouse	`database`	기본 데이터베이스 덮어쓰기
Oracle 데이터베이스	`database`	서비스 이름 덮어쓰기
Microsoft SQL Server	`database`	기본 데이터베이스 덮어쓰기
PostgreSQL	`database`	기본 데이터베이스 덮어쓰기
MongoDB	`database`	기본 데이터베이스 덮어쓰기
Elasticsearch	`timeout`	HTTP 요청 제한 시간, 기본 `10`초
NSQ	`timeout`	HTTP 요청 제한 시간, 기본 `10`초
MQTT Broker, Kafka	-	선택적 매개변수 없음
Prometheus	`timeout`	HTTP 요청 제한 시간, 기본 `10`초
Alibaba Cloud Log Service SLS	-	선택적 매개변수 없음
LLM	`model`, `timeout`	기본 모델 덮어쓰기; 요청 제한 시간 기본 `60`초

위 표에 나열된 매개변수만 해당 작업 객체에 영향을 미칩니다. 다른 추가 매개변수는 호출 진입점에서 받을 수 있지만 커넥터 구현에서는 사용하지 않습니다.

데이터베이스 덮어쓰기

데이터베이스 유형 커넥터에 기본 데이터베이스가 구성되어 있으면 쿼리는 기본 데이터베이스에서 수행됩니다. 이번 작업에서 다른 데이터베이스를 사용해야 하는 경우 커넥터 작업 객체를 가져올 때 database를 전달할 수 있습니다.

Python
db = DFF.CONN('demo_influxdb', database='my_database')

database 매개변수를 지원하는 커넥터는 매개변수 표를 기준으로 합니다. 해당 매개변수를 지원하지 않는 커넥터에서 다른 데이터베이스를 사용해야 하는 경우 별도의 커넥터를 생성해야 합니다.

DataWay는 작업 객체를 가져올 때 커넥터에 저장된 Token을 덮어쓸 수 있습니다.

Python
dataway = DFF.CONN('df_dataway', token='xxxxx')

유형이 다른 커넥터가 반환하는 작업 객체는 서로 다른 메서드를 가집니다. 구체적인 인터페이스는 해당 커넥터 문서를 참조하세요.