七牛---关于GO SDK的各种Demo

netdxy · · 3757 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

具体可以参考七牛GO SDK的源码以及官网使用文档,以下Demo针对V7版本的SDK:
https://github.com/qiniu/go
http://developer.qiniu.com/code/v7/sdk/go.html

文件上传

简单上传

package main

import (
    "github.com/qiniu/api.v7/kodo"
    "qiniupkg.com/api.v7/conf"
    "qiniupkg.com/api.v7/kodocli"
    "fmt"
)

var (
    //设置上传到的空间
    bucket = "yourbucket"
)

//构造返回值字段
type PutRet struct {
    Hash    string `json:"hash"`
    Key     string `json:"key"`
}

func main() {
    //初始化AK,SK
    conf.ACCESS_KEY = "ACCESS_KEY"
    conf.SECRET_KEY = "SECRET_KEY"

    //创建一个Client
    c := kodo.New(0, nil)

    //设置上传的策略
    policy := &kodo.PutPolicy{
        Scope:   bucket,
        //设置Token过期时间
        Expires: 3600,
    }
    //生成一个上传token
    token := c.MakeUptoken(policy);

    //构建一个uploader
    zone := 0
    uploader := kodocli.NewUploader(zone, nil)

    var ret PutRet
    //设置上传文件的路径
    filepath := "/Users/dxy/sync/sample2.flv"
    //调用PutFileWithoutKey方式上传,没有设置saveasKey以文件的hash命名
    res := uploader.PutFileWithoutKey(nil, &ret, token, filepath, nil)
    //打印返回的信息
    fmt.Println(ret)
    //打印出错信息
    if res != nil {
        fmt.Println("io.Put failed:", res)
        return
    }   

}

覆盖上传

package main

import (
    "github.com/qiniu/api.v7/kodo"
    "qiniupkg.com/api.v7/conf"
    "qiniupkg.com/api.v7/kodocli"
    "fmt"
)

var (
    //设置上传到的空间
    bucket = "yourbucket"
    //设置上传文件的key
    key = "yourdefinekey"
)

//构造返回值字段
type PutRet struct {
    Hash    string `json:"hash"`
    Key     string `json:"key"`
}

func main() {
    //初始化AK,SK
    conf.ACCESS_KEY = "ACCESS_KEY"
    conf.SECRET_KEY = "SECRET_KEY"

    //创建一个Client
    c := kodo.New(0, nil)

    //设置上传的策略
    policy := &kodo.PutPolicy{
        Scope:   bucket+ ":" + key,
        //设置Token过期时间
        Expires: 3600,
        InsertOnly: 1,
    }
    //生成一个上传token
    token := c.MakeUptoken(policy);

    //构建一个uploader
    zone := 0
    uploader := kodocli.NewUploader(zone, nil)

    var ret PutRet
    //设置上传文件的路径
    filepath := "/Users/dxy/sync/sample2.flv"
    //调用PutFile方式上传,这里的key需要和上传指定的key一致
    res := uploader.PutFile(nil, &ret, token, key, filepath, nil)
    //打印返回的信息
    fmt.Println(ret)
    //打印出错信息
    if res != nil {
        fmt.Println("io.Put failed:", res)
        return
    }   

}

上传&回调

package main

import (
    "github.com/qiniu/api.v7/kodo"
    "qiniupkg.com/api.v7/conf"
    "qiniupkg.com/api.v7/kodocli"
    "fmt"
)

var (
    //设置上传到的空间
    bucket = "yourbucket"
    //设置上传文件的key
    key = "yourdefinekey"
    //设置CallbackUrl字段
    callbackurl = "http://your.domain.com/callback"
    //设置CallbackBody字段
    callbackbody = `{"key":$(key), "hash":$(etag),"filesize":$(fsize)}`
)

//构造返回值字段
type PutRet struct {
    Hash    string `json:"hash"`
    Key     string `json:"key"`
    Filesize int `json:"filesize"`
}

func main() {
    //初始化AK,SK
    conf.ACCESS_KEY = "ACCESS_KEY"
    conf.SECRET_KEY = "SECRET_KEY"

    //创建一个Client
    c := kodo.New(0, nil)

    //设置上传的策略
    policy := &kodo.PutPolicy{
        Scope:   bucket+ ":" + key,
        //设置Token过期时间
        Expires: 3600,

        CallbackUrl: callbackurl,
        CallbackBody: callbackbody,
    }
    //生成一个上传token
    token := c.MakeUptoken(policy);

    //构建一个uploader
    zone := 0
    uploader := kodocli.NewUploader(zone, nil)

    var ret PutRet
    //设置上传文件的路径
    filepath := "/xxx/xxx/sample.flv"
    //调用PutFile方式上传,这里的key需要和上传指定的key一致
    res := uploader.PutFile(nil, &ret, token, key, filepath, nil)
    //打印返回的信息
    fmt.Println(ret)
    //打印出错信息
    if res != nil {
        fmt.Println("io.Put failed:", res)
        return
    }   

}

上传&预转持续化(以视频转码为例)

package main

import (
    "github.com/qiniu/api.v7/kodo"
    "qiniupkg.com/api.v7/conf"
    "qiniupkg.com/api.v7/kodocli"
    "fmt"
)

var (
    //设置上传到的空间
    bucket = "yourbucket"
    //设置上传文件的key
    key = "yourdefinekey"
    //设置转码参数
    fops = "avthumb/mp4/s/640x360/vb/1.25m"
    //设置转码用的队列
    pipeline = "yourpipeline"
)

//构造返回值字段
type PutRet struct {
    Hash    string `json:"hash"`
    Key     string `json:"key"`
    PersistentId  string `json:"persistentId"`
}

func main() {
    //初始化AK,SK
    conf.ACCESS_KEY = "ACCESS_KEY"
    conf.SECRET_KEY = "SECRET_KEY"

    //创建一个Client
    c := kodo.New(0, nil)

    //设置上传的策略
    policy := &kodo.PutPolicy{
        Scope:   bucket+ ":" + key,
        //设置Token过期时间
        Expires: 3600,
        InsertOnly: 1,
        PersistentOps: fops,
        PersistentPipeline: pipeline,
    }
    //生成一个上传token
    token := c.MakeUptoken(policy);

    //构建一个uploader
    zone := 0
    uploader := kodocli.NewUploader(zone, nil)

    var ret PutRet
    //设置上传文件的路径
    filepath := "/xxx/xxx/sample.flv"
    //调用PutFile方式上传,这里的key需要和上传指定的key一致
    res := uploader.PutFile(nil, &ret, token, key, filepath, nil)
    //打印返回的信息
    fmt.Println(ret)
    //打印出错信息
    if res != nil {
        fmt.Println("io.Put failed:", res)
        return
    }   

}

可以看到上传成功后的回调行为主要是有上传 Token 中的 policy 来指定。其中policy可以指定的行为不止这些,具体可以参考签权类中的policy字段。

文件下载

生成下载链接

package main

import (
    "github.com/qiniu/api.v7/kodo"
    "qiniupkg.com/api.v7/conf"
)

var(
    //指定私有空间的域名
    domain = "xxxx.com2.z0.glb.qiniucdn.com"
    //指定文件的key
    key = "xxx.jpg"
)

//调用封装好的downloadUrl方法生成一个下载链接
func downloadUrl(domain, key string) string {
    //调用MakeBaseUrl()方法将domain,key处理成http://domain/key的形式
    baseUrl := kodo.MakeBaseUrl(domain, key)
    policy := kodo.GetPolicy{}
    //生成一个client对象
    c := kodo.New(0, nil)
    //调用MakePrivateUrl方法返回url
    return c.MakePrivateUrl(baseUrl, &policy)
}

func main() {
    //初始化AK,SK
    conf.ACCESS_KEY = "ACCESS_KEY"
    conf.SECRET_KEY = "SECRET_KEY"
    //打印出下载链接
    println(downloadUrl(domain, key))
}

空间资源的管理

获取文件的信息

package main

import (
    "github.com/qiniu/api.v7/kodo"
    "qiniupkg.com/api.v7/conf"
    "fmt"
)

var (
    //设置需要操作的空间
    bucket = "yourbucket"
    //设置需要操作的文件的key
    key = "yourkey"
)

func main() {

    conf.ACCESS_KEY = "ACCESS_KEY"
    conf.SECRET_KEY = "SECRET_KEY"

    //new一个Bucket管理对象
    c := kodo.New(0, nil)
    p := c.Bucket(bucket)

    //调用Stat方法获取文件的信息
    entry, err := p.Stat(nil, key)
    //打印列取的信息
    fmt.Println(entry)
    //打印出错时返回的信息
    if err != nil {
        fmt.Println(err)
    }
}

移动单个文件

package main

import (
    "github.com/qiniu/api.v7/kodo"
    "qiniupkg.com/api.v7/conf"
    "fmt"
)

var (
    //设置需要操作的空间
    bucket = "yourbucket"
    //设置需要操作的文件的key
    key = "yourkey"
    //设置移动后文件的文件名
    movekey = "movekey"
)

func main() {

    conf.ACCESS_KEY = "ACCESS_KEY"
    conf.SECRET_KEY = "SECRET_KEY"

    //new一个Bucket管理对象
    c := kodo.New(0, nil)
    p := c.Bucket(bucket)

    //调用Move方法移动文件
    res := p.Move(nil, key, movekey)

    //打印返回值以及出错信息
    if res == nil {
        fmt.Println("Move success")
    }else {
        fmt.Println("Move failed:",res)
    }
}

复制单个文件

package main

import (
    "github.com/qiniu/api.v7/kodo"
    "qiniupkg.com/api.v7/conf"
    "fmt"
)

var (
    //设置需要操作的空间
    bucket = "yourbucket"
    //设置需要操作的文件的key
    key = "yourkey"
    //设置复制后文件的文件名
    copykey = "yourcopykey"
)

func main() {

    conf.ACCESS_KEY = "ACCESS_KEY"
    conf.SECRET_KEY = "SECRET_KEY"

    //new一个Bucket管理对象
    c := kodo.New(0, nil)
    p := c.Bucket(bucket)

    //调用Copy方法移动文件
    res := p.Copy(nil, key, copykey)

    //打印返回值以及出错信息
    if res == nil {
        fmt.Println("Copy success")
    }else {
        fmt.Println("Copy failed:",res)
    }
}

删除单个文件

package main

import (
    "github.com/qiniu/api.v7/kodo"
    "qiniupkg.com/api.v7/conf"
    "fmt"
)

var (
    //设置需要操作的空间
    bucket = "yourbucket"
    //设置需要操作的文件的key
    key = "yourkey"
)

func main() {

    conf.ACCESS_KEY = "ACCESS_KEY"
    conf.SECRET_KEY = "SECRET_KEY"

    //new一个Bucket管理对象
    c := kodo.New(0, nil)
    p := c.Bucket(bucket)

    //调用Delete方法删除文件
    res := p.Delete(nil, key)
    //打印返回值以及出错信息
    if res == nil {
        fmt.Println("Delete success")
    }else {
        fmt.Println(res)
    }
}

有疑问加站长微信联系(非本文作者)

本文来自:CSDN博客

感谢作者:netdxy

查看原文:七牛---关于GO SDK的各种Demo

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:1006366459

3757 次点击  
加入收藏 微博
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传