Open API dan SDK

Ditambahkan pada versi 2.6.4

DataFlux Func menyediakan dukungan Open API yang lengkap, dan dapat dipanggil secara terprogram menggunakan DataFlux Func SDK yang disertakan.

1. Mengaktifkan Halaman Dokumentasi Open API

Pada "Fitur Eksperimental", Anda dapat mengaktifkan halaman dokumentasi Open API.

DataFlux Func SDK menyertakan fitur tanda tangan (signature) dan dirilis sebagai file tunggal. Pengguna dapat langsung memasukkannya ke dalam proyek untuk digunakan.

2. Membuat Access Key

1. Masuk ke DataFlux Func Anda
2. Aktifkan manajemen Access Key pada "Manajemen / Fitur Eksperimental"
3. Klik "Buat Baru" pada "Manajemen / Access Key" untuk membuat Access Key

3. Mengirim Permintaan Menggunakan SDK

DataFlux Func SDK mendukung berbagai bahasa pemrograman, dengan tautan unduhan sebagai berikut:

Bahasa	Tautan Unduhan	Keterangan
Python	dataflux_func_sdk.py	Satu file, tanpa dependensi untuk penggunaan dasar. Fungsi unggahan bergantung pada pustaka requests
Node.js	dataflux_func_sdk.js	Satu file, tanpa dependensi untuk penggunaan dasar. Fungsi unggahan bergantung pada pustaka form-data
Golang	dataflux_func_sdk.go	Satu file, sepenuhnya tanpa dependensi Demo: dataflux_func_sdk_demo.go

Berikut contoh pengiriman permintaan:

PythonNode.jsGolang

from dataflux_func_sdk import DataFluxFunc

# Membuat objek operasi DataFlux Func
dff = DataFluxFunc(ak_id='ak-xxxxx', ak_secret='xxxxxxxxxx', host='localhost:8088')

# Mengaktifkan Debug
dff.debug = True

# Mengirim permintaan GET
try:
    status_code, resp = dff.get('/api/v1/do/ping')

except Exception as e:
    print(colored(e, 'red'))
    raise

# Mengirim permintaan POST
try:
    body = {
        'echo': {
            'int'    : 1,
            'str'    : 'Hello World',
            'none'   : None,
            'boolean': True,
        }
    }
    status_code, resp = dff.post('/api/v1/do/echo', body=body)

except Exception as e:
    print(colored(e, 'red'))
    raise

# Mengunggah file
try:
    filename = 'your_file'
    with open(filename, 'rb') as _f:
        file_buffer = _f.read()

    fields = {
        'folder': 'test'
    }

    status_code, resp = dff.upload('/api/v1/resources/do/upload',
        file_buffer=file_buffer,
        filename=filename,
        fields=fields)

except Exception as e:
    print(colored(e, 'red'))
    raise

var fs = require('fs');
var DataFluxFunc = require('./dataflux_func_sdk.js').DataFluxFunc;

// Membuat objek operasi DataFlux Func
var opt = {
  akId    : 'ak-xxxxx',
  akSecret: 'xxxxxxxxxx',
  host    : 'localhost:8088',
};
var dff = new DataFluxFunc(opt);

// Mengaktifkan Debug
dff.debug = true;

// Mengirim permintaan GET
var getOpt = {
  path: '/api/v1/do/ping',
};
dff.get(getOpt, function(err, respData, respStatusCode) {
  if (err) console.error(colored(err, 'red'))

  // Mengirim permintaan POST
  var postOpt = {
    path: '/api/v1/do/echo',
    body: {
      'echo': {
        'int'    : 1,
        'str'    : 'Hello World',
        'none'   : null,
        'boolean': true,
      }
    }
  };
  dff.post(postOpt, function(err, respData, respStatusCode) {
    if (err) console.error(colored(err, 'red'))

    // Mengunggah file
    var filename = 'your_file';
    var uploadOpt = {
      path      : '/api/v1/resources/do/upload',
      fileBuffer: fs.readFileSync(filename),
      filename  : filename,
      fields    : {
        'folder': 'test'
      },
    };
    dff.upload(uploadOpt, function(err, respData, respStatusCode) {
      if (err) console.error(colored(err, 'red'))
    });
  });
});

package main

import (
    "os"
    "bytes"
    "fmt"
    "io"
    "mime/multipart"

    // DataFlux Func SDK
    "./dataflux_func_sdk"
)

var (
    colorMap = map[interface{}]string{
        "grey":    "\033[0;30m",
        "red":     "\033[0;31m",
        "green":   "\033[0;32m",
        "yellow":  "\033[0;33m",
        "blue":    "\033[0;34m",
        "magenta": "\033[0;35m",
        "cyan":    "\033[0;36m",
    }
)

func main() {
    host := "localhost:8088"
    if len(os.Args) >= 2 {
        host = os.Args[1]
    }

    // Membuat objek operasi DataFlux Func
    dff := dataflux_func_sdk.NewDataFluxFunc("ak-xxxxx", "xxxxxxxxxx", host, 30, false)

    // Mengaktifkan Debug
    dff.Debug = true

    // Mengirim permintaan GET
    _, _, err := dff.Get("/api/v1/do/ping", nil, nil, "")
    if err != nil {
        panic(err)
    }

    // Mengirim permintaan POST
    body := map[string]interface{}{
        "echo": map[string]interface{}{
            "int"    : 1,
            "str"    : "Hello World",
            "none"   : nil,
            "boolean": true,
        },
    }
    _, _, err = dff.Post("/api/v1/do/echo", body, nil, nil, "")
    if err != nil {
        panic(err)
    }

    // Mengunggah file
    filename := "dataflux_func_sdk_demo.go"
    file, _ := os.Open(filename)
    fileContents, _ := io.ReadAll(file)

    uploadBody := &bytes.Buffer{}
    writer := multipart.NewWriter(uploadBody)

    part, _ := writer.CreateFormFile("files", filename)
    part.Write(fileContents)

    fields := map[string]string{
        "folder": "test",
    }
    for key, value := range fields {
        writer.WriteField(key, fmt.Sprintf("%v", value))
    }

    writer.Close()
    contentType := writer.FormDataContentType()

    _, _, err = dff.Upload("/api/v1/resources/do/upload", filename, "", fields, nil, nil, uploadBody, contentType)
    if err != nil {
        panic(err)
    }
}