使用Golang调用腾讯云对象存储（COS）

2024-05-26 02:52
文章标签 golang 使用 对象 调用 存储 腾讯 cos

本文主要是介绍使用Golang调用腾讯云对象存储（COS），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

  • 一、腾讯云COS对象存储创建
    • 1.1 创建存储桶
    • 2.1 存储桶测试
  • 二、使用Golang调用腾讯云对象存储（COS）
    • 2.1 安装COS SDK
    • 2.2 初始化COS客户端
    • 2.3 上传文件
    • 2.4 下载文件
    • 2.5 列出存储桶中的对象
    • 2.6 整体代码示例

本文档介绍如何使用Golang调用腾讯云对象存储（COS），包括初始化客户端、上传文件和下载文件。

一、腾讯云COS对象存储创建

1.1 创建存储桶

  1. 我们需要创建一个用于存放对象的存储桶：

  2. 在 对象存储控制台 左侧导航栏中单击存储桶列表，进入存储桶管理页。

  3. 单击创建存储桶，输入以下配置信息，其他配置保持默认即可。

名称：输入存储桶名称。名称设置后不可修改。此处举例输入 exampleobjext 。所属地域：存储桶所属地域，选择与您业务最近的一个地区，例如香港地域。访问权限：存储桶访问权限，此处我们保持默认为“私有读写”。单击确定，即可创建完成。

2.1 存储桶测试

  • 上传对象

从本地选择文件上传到存储桶：

  1. 单击存储桶名称，进入存储桶列表页。

  2. 选择上传文件 > 选择文件，选择需要上传至存储桶的文件，例如文件名为 exampleobjext.txt 的文件。

  3. 单击上传，即可将文件 exampleobjext.txt 上传至存储桶。

  • 下载对象

将云上数据下载到本地：

1.单击文件 exampleobjext.txt 右侧的详情，进入对象属性页。

2.在基本信息配置项中，单击下载对象即可下载，或单击复制临时链接，将链接粘贴至浏览器地址栏并回车，即可下载该对象。

  • 删除对象

将云上对象数据删除：

  1. 在左侧导航栏中，单击【存储桶列表】，进入存储桶列表页面。

  2. 找到对象所在的存储桶，单击其存储桶名称，进入存储桶管理页面。

  3. 在左侧导航栏中，选择【文件列表】，进入文件列表页面。

  4. 勾选需要删除的对象，单击上方的【更多操作】>【删除】。

二、使用Golang调用腾讯云对象存储（COS）

2.1 安装COS SDK

go get -u github.com/tencentyun/cos-go-sdk-v5

2.2 初始化COS客户端

package mainimport ("context""fmt""github.com/tencentyun/cos-go-sdk-v5""net/http""net/url"
)func initCOSClient(bucketName, region, secretID, secretKey string) *cos.Client {u, _ := url.Parse(fmt.Sprintf("https://%s.cos.%s.myqcloud.com", bucketName, region))b := &cos.BaseURL{BucketURL: u}return cos.NewClient(b, &http.Client{Transport: &cos.AuthorizationTransport{SecretID:  secretID,SecretKey: secretKey,},})
}func main() {client := initCOSClient("<your-bucket-name>", "<region>", "<your-secret-id>", "<your-secret-key>")fmt.Println("COS client initialized successfully.")
}

2.3 上传文件

下面的函数用于将本地文件上传到COS。

  • 上传文件方法
func uploadFile(client *cos.Client, localFilePath, remoteFilePath string) error {fmt.Printf("Uploading file from %s to %s\n", localFilePath, remoteFilePath)f, err := os.Open(localFilePath)if err != nil {return fmt.Errorf("opening file: %v", err)}defer f.Close()_, err = client.Object.Put(context.Background(), remoteFilePath, f, nil)if err != nil {return fmt.Errorf("uploading file: %v", err)}return nil
}
  • 方法调用示例
func main() {client := initCOSClient("<your-bucket-name>", "<region>", "<your-secret-id>", "<your-secret-key>")localUploadPath := "local/path/to/example.txt"remoteUploadPath := "remote/path/to/example.txt"err := uploadFile(client, localUploadPath, remoteUploadPath)if err != nil {fmt.Println("Error uploading file:", err)} else {fmt.Println("File uploaded successfully.")}
}

2.4 下载文件

下面的函数用于从COS下载文件并保存到本地。

  • 下载文件方法
func downloadFile(client *cos.Client, remoteFilePath, localFilePath string) error {fmt.Printf("Downloading file from %s to %s\n", remoteFilePath, localFilePath)// 确保目录存在dir := filepath.Dir(localFilePath)if err := os.MkdirAll(dir, 0755); err != nil {return fmt.Errorf("creating directories: %v", err)}resp, err := client.Object.Get(context.Background(), remoteFilePath, nil)if err != nil {return fmt.Errorf("downloading file: %v", err)}defer resp.Body.Close()localFile, err := os.Create(localFilePath)if err != nil {return fmt.Errorf("creating file: %v", err)}defer localFile.Close()_, err = localFile.ReadFrom(resp.Body)if err != nil {return fmt.Errorf("writing to file: %v", err)}return nil
}
  • 方法调用示例
func main() {client := initCOSClient("<your-bucket-name>", "<region>", "<your-secret-id>", "<your-secret-key>")localDownloadPath := "local/path/to/downloaded_example.txt"remoteDownloadPath := "remote/path/to/example.txt"err := downloadFile(client, remoteDownloadPath, localDownloadPath)if err != nil {fmt.Println("Error downloading file:", err)} else {fmt.Println("File downloaded successfully.")}
}

2.5 列出存储桶中的对象

有时候我们可能需要列出存储桶中的对象以确认文件是否存在。

func listObjects(client *cos.Client, prefix string) error {opt := &cos.BucketGetOptions{Prefix: prefix,}v, _, err := client.Bucket.Get(context.Background(), opt)if err != nil {return fmt.Errorf("listing objects: %v", err)}for _, c := range v.Contents {fmt.Println(c.Key)}return nil
}func main() {client := initCOSClient("<your-bucket-name>", "<region>", "<your-secret-id>", "<your-secret-key>")// 列出存储桶中的对象err := listObjects(client, "remote/path/to/")if err != nil {fmt.Println("Error listing objects:", err)}
}

2.6 整体代码示例

package mainimport ("context""fmt""github.com/tencentyun/cos-go-sdk-v5""net/http""net/url""os""path/filepath"
)func main() {// 初始化COS客户端client := initCOSClient("<your-bucket-name>", "<region>", "<your-secret-id>", "<your-secret-key>")// 上传文件localUploadPath := "local/path/to/example.txt"remoteUploadPath := "remote/path/to/example.txt"err := uploadFile(client, localUploadPath, remoteUploadPath)if err != nil {fmt.Println("Error uploading file:", err)} else {fmt.Println("File uploaded successfully.")}// 下载文件localDownloadPath := "local/path/to/downloaded_example.txt"remoteDownloadPath := "remote/path/to/example.txt"err = downloadFile(client, remoteDownloadPath, localDownloadPath)if err != nil {fmt.Println("Error downloading file:", err)} else {fmt.Println("File downloaded successfully.")}// 列出存储桶中的对象err = listObjects(client, "remote/path/to/")if err != nil {fmt.Println("Error listing objects:", err)}
}// 初始化COS客户端
func initCOSClient(bucketName, region, secretID, secretKey string) *cos.Client {u, _ := url.Parse(fmt.Sprintf("https://%s.cos.%s.myqcloud.com", bucketName, region))b := &cos.BaseURL{BucketURL: u}return cos.NewClient(b, &http.Client{Transport: &cos.AuthorizationTransport{SecretID:  secretID,SecretKey: secretKey,},})
}// 上传文件
func uploadFile(client *cos.Client, localFilePath, remoteFilePath string) error {fmt.Printf("Uploading file from %s to %s\n", localFilePath, remoteFilePath)f, err := os.Open(localFilePath)if err != nil {return fmt.Errorf("opening file: %v", err)}defer f.Close()_, err = client.Object.Put(context.Background(), remoteFilePath, f, nil)if err != nil {return fmt.Errorf("uploading file: %v", err)}return nil
}// 下载文件
func downloadFile(client *cos.Client, remoteFilePath, localFilePath string) error {fmt.Printf("Downloading file from %s to %s\n", remoteFilePath, localFilePath)// 确保目录存在dir := filepath.Dir(localFilePath)if err := os.MkdirAll(dir, 0755); err != nil {return fmt.Errorf("creating directories: %v", err)}resp, err := client.Object.Get(context.Background(), remoteFilePath, nil)if err != nil {return fmt.Errorf("downloading file: %v", err)}defer resp.Body.Close()localFile, err := os.Create(localFilePath)if err != nil {return fmt.Errorf("creating file: %v", err)}defer localFile.Close()_, err = localFile.ReadFrom(resp.Body)if err != nil {return fmt.Errorf("writing to file: %v", err)}return nil
}// 列出存储桶中的对象
func listObjects(client *cos.Client, prefix string) error {opt := &cos.BucketGetOptions{Prefix: prefix,}v, _, err := client.Bucket.Get(context.Background(), opt)if err != nil {return fmt.Errorf("listing objects: %v", err)}for _, c := range v.Contents {fmt.Println(c.Key)}return nil
}

参考文档：

  • 腾讯云对象存储创建文档：https://cloud.tencent.com/document/product/436/14106
  • 腾讯云对象存储golang-SDK：https://cloud.tencent.com/document/product/436/31215
  • 腾讯云对象存储常见问题：https://cloud.tencent.com/document/product/436/30748

这篇关于使用Golang调用腾讯云对象存储（COS）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1003347。

相关文章

GO语言中函数命名返回值的使用

GO语言中函数命名返回值的使用

《GO语言中函数命名返回值的使用》在Go语言中,函数可以为其返回值指定名称,这被称为命名返回值或命名返回参数,这种特性可以使代码更清晰,特别是在返回多个值时,感兴趣的可以了解一下... 目录基本语法函数命名返回特点代码示例命名特点基本语法func functionName(parameters) (nam
阅读更多...
使用shardingsphere实现mysql数据库分片方式

使用shardingsphere实现mysql数据库分片方式

《使用shardingsphere实现mysql数据库分片方式》本文介绍如何使用ShardingSphere-JDBC在SpringBoot中实现MySQL水平分库,涵盖分片策略、路由算法及零侵入配置... 目录一、ShardingSphere 简介1.1 对比1.2 核心概念1.3 Sharding-Sp
阅读更多...
Java 正则表达式的使用实战案例

Java 正则表达式的使用实战案例

《Java正则表达式的使用实战案例》本文详细介绍了Java正则表达式的使用方法,涵盖语法细节、核心类方法、高级特性及实战案例,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要... 目录一、正则表达式语法详解1. 基础字符匹配2. 字符类（[]定义）3. 量词（控制匹配次数）4. 边
阅读更多...
Python Counter 函数使用案例

Python Counter 函数使用案例

《PythonCounter函数使用案例》Counter是collections模块中的一个类,专门用于对可迭代对象中的元素进行计数,接下来通过本文给大家介绍PythonCounter函数使用案例... 目录一、Counter函数概述二、基本使用案例（一）列表元素计数（二）字符串字符计数（三）元组计数三、C
阅读更多...
使用Spring Cache本地缓存示例代码

使用Spring Cache本地缓存示例代码

《使用SpringCache本地缓存示例代码》缓存是提高应用程序性能的重要手段,通过将频繁访问的数据存储在内存中,可以减少数据库访问次数,从而加速数据读取,：本文主要介绍使用SpringCac... 目录一、Spring Cache简介核心特点：二、基础配置1. 添加依赖2. 启用缓存3. 缓存配置方案方案
阅读更多...
使用Python的requests库来发送HTTP请求的操作指南

使用Python的requests库来发送HTTP请求的操作指南

《使用Python的requests库来发送HTTP请求的操作指南》使用Python的requests库发送HTTP请求是非常简单和直观的,requests库提供了丰富的API,可以发送各种类型的HT... 目录前言1. 安装 requests 库2. 发送 GET 请求3. 发送 POST 请求4. 发送
阅读更多...
Nginx中配置使用非默认80端口进行服务的完整指南

Nginx中配置使用非默认80端口进行服务的完整指南

《Nginx中配置使用非默认80端口进行服务的完整指南》在实际生产环境中,我们经常需要将Nginx配置在其他端口上运行,本文将详细介绍如何在Nginx中配置使用非默认端口进行服务,希望对大家有所帮助... 目录一、为什么需要使用非默认端口二、配置Nginx使用非默认端口的基本方法2.1 修改listen指令
阅读更多...
Python WebSockets 库从基础到实战使用举例

Python WebSockets 库从基础到实战使用举例

《PythonWebSockets库从基础到实战使用举例》WebSocket是一种全双工、持久化的网络通信协议,适用于需要低延迟的应用,如实时聊天、股票行情推送、在线协作、多人游戏等,本文给大家介... 目录1. 引言2. 为什么使用 WebSocket？3. 安装 WebSockets 库4. 使用 We
阅读更多...
python中的显式声明类型参数使用方式

python中的显式声明类型参数使用方式

《python中的显式声明类型参数使用方式》文章探讨了Python3.10+版本中类型注解的使用,指出FastAPI官方示例强调显式声明参数类型,通过|操作符替代Union/Optional,可提升代... 目录背景python函数显式声明的类型汇总基本类型集合类型Optional and Union(py
阅读更多...
Java使用正则提取字符串中的内容的详细步骤

Java使用正则提取字符串中的内容的详细步骤

《Java使用正则提取字符串中的内容的详细步骤》：本文主要介绍Java中使用正则表达式提取字符串内容的方法,通过Pattern和Matcher类实现,涵盖编译正则、查找匹配、分组捕获、数字与邮箱提... 目录1. 基础流程2. 关键方法说明3. 常见场景示例场景1：提取所有数字场景2：提取邮箱地址4. 高级
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2