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

具体可以参考七牛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)
 }
}

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

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传