Qiniu Go SDK v7

The SDK is organized into several functional modules covering Object Storage, Cloud Services, and Infrastructure:

Object Storage (v2 API Recommended)

• storagev2: Core v2 API with typed requests/responses, auto-region detection, and connection pooling.
• storagev2/uploader: Manages uploads (automatically selects between form or chunked upload).
• storagev2/downloader: Manages downloads with concurrent chunk support.
• storagev2/objects: Object management via a chainable API (query, copy, move, delete, etc.).
• storagev2/credentials: Credential management via CredentialsProvider interface.
• storagev2/uptoken: Upload token management using PutPolicy.
• storagev2/region: Region information and endpoint management.
• storagev2/apis: Low-level typed APIs.
• storage: Legacy v1 API.

Other Cloud Services

• auth: Authentication and signing (AK/SK, request signing, callback verification).
• cdn: CDN acceleration (refresh, prefetch, traffic/bandwidth queries, logs).
• pili: Live streaming (Hub/Stream management, URL generation).
• rtc: Real-time audio/video (RoomToken, room management).
• sms: SMS services (sending, signature/template management).
• qvs: Video surveillance (GB/T 28181 device management, recording, snapshots).
• linking: IoT device connectivity (device management, keys).
• iam: Identity and Access Management (sub-accounts, groups, policies).
• media: Multimedia data processing (triggering and querying persistent processing).
• audit: Audit logs (account operation auditing).
• sandbox: Sandbox services (lifecycle, file ops, command execution).

Infrastructure

• client: Underlying HTTP client.
• storagev2/http_client: storagev2 specific HTTP client and options.
• reqid: Request ID propagation.
• conf: Global SDK configuration.

The Pili SDK provides programmatic access to the following functional modules:

URL Generation and Signing

• Generate RTMP/SRT push URLs and RTMP/HLS/HDL(FLV) playback URLs.
• Perform live stream authentication (push URL signing).
• Perform anti-leech protection (playback URL timestamp signing).

Live Space Management (Hub)

• Query lists and details of live streaming spaces (hubs).
• Configure security (push authentication), HLS low latency, persistence (storage), and snapshot (cover image) settings for a hub.

Domain Management (Domain)

• Query and manage domains associated with a hub.
• Bind new live domains or unbind existing ones.
• Configure VOD domains, SSL certificates, and URL rewrite rules.

Stream Management (Stream)

• Query live stream lists and specific stream information.
• Disable live streams and query online stream status (individual or batch).
• Access stream history, record live streams for playback, save snapshots, and modify transcoding configurations.

Data Statistics (Stat)

• Monitor upflow and downflow traffic.
• Track usage for live transcoding, content moderation (nrop), caster (studio), and Pub services.

This example demonstrates how to initialize credentials, create an upload policy, and use the uploader.UploadManager to upload a file using the recommended storagev2 API.

1. Obtain your AccessKey and SecretKey from the Qiniu Portal.
2. Use credentials.NewCredentials to create your identity.
3. Use uptoken.NewPutPolicy to define the target bucket and expiration.
4. Use uploader.NewUploadManager with http_client.Options to manage the upload process.

package main

import (
    "context"
    "fmt"
    "time"

    "github.com/qiniu/go-sdk/v7/storagev2/credentials"
    "github.com/qiniu/go-sdk/v7/storagev2/http_client"
    "github.com/qiniu/go-sdk/v7/storagev2/uploader"
    "github.com/qiniu/go-sdk/v7/storagev2/uptoken"
)

func main() {
    // 创建凭证（AK/SK 从 https://portal.qiniu.com/user/key 获取）
    cred := credentials.NewCredentials("AccessKey", "SecretKey")

    // 创建上传策略和凭证
    putPolicy, _ := uptoken.NewPutPolicy("my-bucket", time.Now().Add(time.Hour))

    // 创建上传管理器
    uploadManager := uploader.NewUploadManager(&uploader.UploadManagerOptions{
        Options: http_client.Options{Credentials: cred},
    })

    // 上传文件
    objectName := "my-file.txt"
    err := uploadManager.UploadFile(context.Background(), "/path/to/file", &uploader.ObjectOptions{
        BucketName: "my-bucket",
        ObjectName: &objectName,
        UpToken:    uptoken.NewSigner(putPolicy, cred),
    }, nil)
    if err != nil {
        fmt.Println("上传失败:", err)
        return
    }
    fmt.Println("上传成功")
}

Manage access keys (DAK) for devices using the following methods:

• AddDeviceKey(appid, device string): Create a new device key.
• QueryDeviceKey(appid, device string) ([]string, error): List keys associated with a device.
• DeleteDeviceKey(appid, device, dak string): Delete a specific device key.
• UpdateDeviceKeyState(appid, device, dak string, state int): Enable or disable a device key (e.g., state: 1 to enable).
• CloneDeviceKey(appid, fromdevice, todevice string, cleanSelfKeys, deleteDevice bool, deviceAccessKey string) ([]string, error): Clone a device key from one device to another.
• QueryAppidDeviceNameByAccessKey(dak string) (appid, device string, err error): Look up the appid and device name using a specific device access key (DAK).

// Example: Clone a device key
keys, err := manager.CloneDeviceKey(Appid, device1, device2, false, false, dak1)

// Example: Query device info by access key
appid, device, err := manager.QueryAppidDeviceNameByAccessKey(dak)