附件同步到华为云OBS存储备份实践（服务端API应用）

最近在了解华为云OBS存储，所以就用活字格6做了一个附件同步备份。

本示例只实现了添加同步，修改和删除同步没有做。
另外有关OBS桶的创建、删除的操作示例还在测试中。

还有就是本人对c#编程并不是很熟悉，所以后面的API实现代码写得不是很好，大家可以参考优化。

在开发本示例过程中，如果活字格有如下改进则更好（也许已有只是我不知道而已）：
1、服务命令也可以发起POST请求，这样就不用在前端使用javascript命令了，效果更好；
2、数据表操作添加新数据后，能直接获取到新加记录的ID，那就更加方便了。
3、服务端操作数据表时，如果能直接写sql语句，则更好。
4、可以获取一些系统变量（如附件存储目录），或是自定义一些系统变量则更好（如AK值写到系统变量则更加方便获取）？

相关步骤如下。

1、在华为云注册账号并获取AK、SK，详细可见：https://support.huaweicloud.com/api-obs/obs_04_0116.html

2、在OBS控制台创建桶。

3、下载OBS开发SDK，详细见：https://support.huaweicloud.com/ ... bs/obs_25_0001.html
      下载最新版。
  

4、使用vs2019开发服务端api应用，详细可见过个教程：https://help.grapecity.com.cn/pa ... ion?pageId=23594298
     要注意，还要把第三步下载的SDK添加到引用中
   

5、编写API代码，生成dll

6、活字格中上传api

7、开发应用






8、做好配置


9、运行效果


OBS可以看到同步的文件。



示例工程如下：
附件同步华为云OBS存储备份(无AKSK).fgcc (317.87 KB, 下载次数: 221)

2020-3-17 13:03 上传

点击文件名下载附件
阅读权限: 1

vs2019的API源代码如下：

1. using System;
   
2. using System.Collections.Generic;
   
3. using System.Linq;
   
4. using System.Text;
   
5. using System.Threading.Tasks;
   
6. using GrapeCity.Forguncy.ServerApi;
   
7. using OBS;
   
8. using OBS.Model;
   
9. 
   
10. namespace FileToHuaweiOBS
    
11. {
    
12.     public class FileToHuaweiOBS :ForguncyApi
    
13.     {
    
14.         private static string endpoint = "";
    
15.         private static string AK = "";
    
16.         private static string SK = "";
    
17. 
    
18.         private string LocalPath = ""; //本地附件目录
    
19. 
    
20.         private string defaultObsregion = ""; //默认区域
    
21.         private string defaultBucketName = ""; //默认桶名
    
22.         private string obsregion    = ""; //区域
    
23.         private string BucketName   = ""; //桶名
    
24.         private string optype       = ""; //操作类型
    
25. 
    
26.         private string resultCode = "";
    
27.         private string resultMsg = "";
    
28. 
    
29.         //日志记录
    
30.         Dictionary<string, object> LogValues = new Dictionary<string, object>();
    
31. 
    
32. 
    
33.         [Post]
    
34.         public void obsApi()
    
35.         {
    
36.             //获取post请求的数据
    
37.             var form = this.Context.Request.ReadFormAsync().Result;
    
38.             obsregion = form["obsregion"];
    
39.             optype    = form["optype"];
    
40. 
    
41.             LogSave("api", "接收到POST", "操作：" + optype);
    
42. 
    
43.             optype = optype.ToLower();
    
44. 
    
45.             //预留其他操作扩展
    
46.             switch (optype)
    
47.             {
    
48.                  case "fileasync":
    
49.                     BucketName = form["BucketName"];                    
    
50.                     obsObjectAsync(obsregion, BucketName);
    
51.                     break;
    
52.                 default:
    
53.                     this.resultCode = "1";
    
54.                     this.resultMsg = "操作方法错误";
    
55.                     break;
    
56.             }
    
57. 
    
58. 
    
59.             //定义返回结果;
    
60.             //转换数据类型为string
    
61.             if (resultCode == "0")
    
62.             {
    
63.                 string result = Convert.ToString("0");
    
64.                 this.Context.Response.Write(result.ToString());
    
65.             }
    
66.             else
    
67.             {
    
68.                 string result = Convert.ToString("1") + "，" + this.resultMsg;
    
69.                 this.Context.Response.Write(result.ToString());
    
70.             }
    
71. 
    
72.         }
    
73. 
    
74.         //OBS授权访问信息
    
75.         public void obsAuth()
    
76.         {
    
77. 
    
78.             //获取默认区域
    
79.             var data = DataAccess.GetTableData(string.Format("访问配置?$select=配置项值&$filter=配置项索引 eq 'obsregion'")) as List<Dictionary<string, object>>;
    
80.             if (data.Count != 0)
    
81.             {
    
82.                 //获取默认区域
    
83.                 defaultObsregion = data[0]["配置项值"].ToString();
    
84.                 //LogSave("OBS", "获取默认区域", defaultObsregion );
    
85.             }
    
86. 
    
87.             //获取默认桶
    
88.             data = DataAccess.GetTableData(string.Format("访问配置?$select=配置项值&$filter=配置项索引 eq 'BucketName'")) as List<Dictionary<string, object>>;
    
89.             if (data.Count != 0)
    
90.             {
    
91.                 //获取默认桶
    
92.                 defaultBucketName = data[0]["配置项值"].ToString();
    
93.                 //LogSave("OBS", "获取默认桶", defaultBucketName );
    
94.             }
    
95. 
    
96.             if (obsregion == "")
    
97.             {
    
98.                 obsregion = defaultObsregion;//设置默认区域
    
99.             }
    
100.             //获取区域endpoint
     
101.             data = DataAccess.GetTableData(string.Format("区域终节点?$select=终节点&$filter=区域代码 eq '"+ obsregion + "'")) as List<Dictionary<string, object>>;
     
102.             if (data.Count != 0)
     
103.             {
     
104.                 //endpoint
     
105.                 endpoint = data[0]["终节点"].ToString();
     
106.                 //LogSave("OBS", "endpoint", endpoint);
     
107.             }
     
108. 
     
109.             //获取AK
     
110.             data = DataAccess.GetTableData(string.Format("访问配置?$select=配置项值&$filter=配置项索引 eq 'OBSAK'")) as List<Dictionary<string, object>>;
     
111.             if (data.Count != 0)
     
112.             {
     
113.                 //AK
     
114.                 AK = data[0]["配置项值"].ToString();
     
115.                 //LogSave("OBS", "AK", AK);//正式启用时注释此行，防止AK泄露
     
116.             }
     
117. 
     
118.             //获取SK
     
119.             data = DataAccess.GetTableData(string.Format("访问配置?$select=配置项值&$filter=配置项索引 eq 'OBSSK'")) as List<Dictionary<string, object>>;
     
120.             if (data.Count != 0)
     
121.             {
     
122.                 //SK
     
123.                 SK = data[0]["配置项值"].ToString();
     
124.                 //LogSave("OBS", "SK", SK);//正式启用时注释此行，防止SK泄露
     
125.             }
     
126. 
     
127.             //获取本地附件目录
     
128.             data = DataAccess.GetTableData(string.Format("访问配置?$select=配置项值&$filter=配置项索引 eq 'LOCALPATH'")) as List<Dictionary<string, object>>;
     
129.             if (data.Count != 0)
     
130.             {
     
131.                 //LocalPath
     
132.                 LocalPath = data[0]["配置项值"].ToString();
     
133.                 //LogSave("OBS", "LocalPath", LocalPath);
     
134.             }
     
135. 
     
136.         }
     
137. 
     
138.         public void obsObjectAsync(string obsregion, string BucketName)
     
139.         {
     
140.             obsAuth();
     
141. 
     
142.             //检查AK\SK\endpoint是否获取到
     
143.             if (AK == "" || SK == "" || endpoint == "") {
     
144.                 LogSave("OBS", "AK、SK、endpoint", "缺少配置");
     
145.                 return;
     
146.             }
     
147. 
     
148. 
     
149.             if (BucketName == "")
     
150.             {
     
151.                 BucketName = defaultBucketName;//设置默认桶
     
152.             }
     
153. 
     
154. 
     
155.             // 创建ObsClient实例
     
156. 
     
157.             ObsClient client = new ObsClient(AK, SK, endpoint);
     
158. 
     
159.             int maxfileid = 0;
     
160.             string filepaths = "";
     
161.             string appUpLoadPath = LocalPath;// "C:\\ProgramData\\Forguncy\\ibm\\3725\\WebSite\\Upload\";
     
162. 
     
163. 
     
164.             LogSave("OBS桶对象Async", "maxfileid", "0");
     
165.             var data = DataAccess.GetTableData(string.Format("文件表?$select=ID,附件&$filter=obs状态 eq 0&$top=1&$orderby=ID desc")) as List<Dictionary<string, object>>;
     
166.             if (data.Count != 0)
     
167.             {
     
168.                 maxfileid = Convert.ToInt32(data[0]["ID"].ToString());
     
169.                 filepaths = data[0]["附件"].ToString();
     
170.             }
     
171. 
     
172.             LogSave("OBS桶对象Async", "filepaths成功", filepaths);
     
173. 
     
174.             string[] filepathArray = filepaths.Split('|');
     
175. 
     
176.             // 上传文件
     
177.             if (maxfileid >= 0)
     
178.             {
     
179.                 try
     
180.                 {
     
181.                     foreach (string filename in filepathArray)
     
182.                     {
     
183.                         if (filename != "")
     
184.                         {
     
185.                             LogSave("OBS桶对象Async", "开始同步", filename);
     
186.                             LogSave("OBS桶对象Async", "开始同步FilePath", appUpLoadPath + filename);
     
187.                             LogSave("OBS桶对象Async", "开始同步到桶", BucketName);
     
188.                             PutObjectRequest request = new PutObjectRequest()
     
189.                             {
     
190.                                 BucketName = BucketName,
     
191.                                 ObjectKey = filename,
     
192.                                 FilePath = appUpLoadPath + filename,//待上传的本地文件路径，需要指定到具体的文件名
     
193.                             };
     
194. 
     
195.                             PutObjectResponse response = client.PutObject(request);
     
196.                             LogSave("OBS桶对象", "文件同步成功", filename);
     
197.                         }
     
198.                     }
     
199. 
     
200. 
     
201. 
     
202.                     //定义键为string,值为object类型的Dictionary
     
203.                     Dictionary<string, object> values = new Dictionary<string, object>();
     
204.                     //定义要更新的记录
     
205.                     ColumnValuePair valuepair = new ColumnValuePair();
     
206.                     valuepair.ColumnName = "ID";
     
207.                     valuepair.Value = maxfileid;
     
208. 
     
209.                     //要被更新的值，Key表示列名，值是要被更新的值
     
210.                     values = new Dictionary<string, object>();
     
211.                     values.Add("obs状态", 1);
     
212. 
     
213.                     //使用UpdateTableData方法更新OBS状态
     
214.                     this.DataAccess.UpdateTableData("文件表", valuepair, values);
     
215. 
     
216.                 }
     
217.                 catch (ObsException ex)
     
218.                 {
     
219.                     LogSave("OBS桶对象", "文件同步失败，" + ex.ErrorCode, ex.ErrorMessage);
     
220.                 }
     
221. 
     
222.             }
     
223. 
     
224.         }
     
225. 
     
226. 
     
227.         public void LogSave(string logType, string logTitle, string logBody)
     
228.         {
     
229.             Dictionary<string, object> tempLogValues = new Dictionary<string, object>();
     
230.             tempLogValues.Clear();
     
231.             tempLogValues.Add("日志类型", logType);
     
232.             tempLogValues.Add("标题", logTitle);
     
233.             tempLogValues.Add("内容", logBody);
     
234.             tempLogValues.Add("时间", DateTime.Now.ToString("hh:mm:ss"));
     
235.             tempLogValues.Add("日期", DateTime.Now.ToString("yyyy-MM-dd"));
     
236.             this.DataAccess.AddTableData("日志", tempLogValues);
     
237.         }
     
238.     }
     
239. 
     
240. 
     
241. }
     

复制代码

大神求带~

Simon.hu 发表于 2020-3-18 09:30
大神求带~

我都是看胡总的视频学习的。