Lewati ke isi

Pengembangan Skrip / Objek Konektor DFF.CONN / Ikhtisar

Setelah membuat Konektor, Anda dapat memanggil DFF.CONN(connector_id, **kwargs) dalam kode untuk mendapatkan objek operasi Konektor yang ditentukan.

Parameter Tipe Wajib / Nilai Default Deskripsi
connector_id str Wajib ID Konektor
**kwargs - - Menimpa sebagian konfigurasi objek operasi saat ini; cakupan dukungan bergantung pada tipe Konektor

Parameter opsional yang nilainya None atau string kosong akan diabaikan. Jika parameter opsional tidak diberikan, objek operasi menggunakan konfigurasi yang disimpan di Konektor atau nilai default kode.

Contoh
1
2
3
4
@DFF.API('Demonstrasi Operasi InfluxDB')
def influxdb_demo():
    db = DFF.CONN('demo_influxdb')
    return db.query('SELECT * FROM demo LIMIT 3')

Parameter opsional yang didukung oleh masing-masing Konektor adalah sebagai berikut:

Tipe Konektor Parameter Opsional Deskripsi
Guance Cloud, TrueWatch timeout Waktu tunggu permintaan HTTP, default 10 detik
DataKit source, timeout, split_size Menimpa Source, waktu tunggu permintaan, dan ukuran pemecahan batch
DataWay token, timeout, split_size Menimpa Token, waktu tunggu permintaan, dan ukuran pemecahan batch
DataFlux Func Sidecar timeout Waktu tunggu permintaan HTTP, default 10 detik
InfluxDB database Menimpa database default
MySQL database Menimpa database default
Redis database, client_name Menimpa nomor database dan nama klien Redis
Memcached - Tidak ada parameter opsional
ClickHouse database Menimpa database default
Oracle Database database Menimpa nama layanan
Microsoft SQL Server database Menimpa database default
PostgreSQL database Menimpa database default
MongoDB database Menimpa database default
Elasticsearch timeout Waktu tunggu permintaan HTTP, default 10 detik
NSQ timeout Waktu tunggu permintaan HTTP, default 10 detik
MQTT Broker, Kafka - Tidak ada parameter opsional
Prometheus timeout Waktu tunggu permintaan HTTP, default 10 detik
Alibaba Cloud Log Service SLS - Tidak ada parameter opsional
LLM model, timeout Menimpa model default; waktu tunggu permintaan default 60 detik

Hanya parameter yang tercantum dalam tabel di atas yang memengaruhi objek operasi terkait. Parameter tambahan lainnya mungkin diterima oleh titik masuk panggilan, tetapi tidak akan digunakan oleh implementasi Konektor.

Menimpa Database

Jika Konektor tipe database dikonfigurasi dengan database default, kueri akan berjalan di database default. Jika operasi kali ini perlu menggunakan database lain, Anda dapat meneruskan database saat mendapatkan objek operasi Konektor:

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

Untuk Konektor yang mendukung parameter database, ikuti tabel parameter. Untuk Konektor yang tidak mendukung parameter ini, jika perlu mengoperasikan database lain, buatlah Konektor yang berbeda.

Menimpa Token DataWay

DataWay dapat menimpa Token yang disimpan di Konektor saat mendapatkan objek operasi:

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

Objek operasi yang dikembalikan oleh berbagai jenis Konektor memiliki metode yang berbeda; untuk antarmuka spesifik, lihat dokumentasi Konektor yang bersangkutan.