Unity 上傳文件到 GCP Cloud Storage

1
2```csharp
3using Google.Cloud.Storage.V1;
4using System;
5using System.IO;
6using System.Threading.Tasks;
7using Google.Apis.Auth.OAuth2;
8using Google.Apis.Upload;
9using UnityEngine;
10using UnityEngine.Networking;
11using YFrame.Utility;
12
13namespace YFrame.API.Google.CloudStorage
14{
15    public class CStorageImp : ICloudStorage
16    {
17        public string BucketName = "your-bucket-name";
18        public string JsonCrePath = "path-to-your-service-account-json-key-file";
19
20        private StorageClient storageClient;
21
22        public void Initialize(string bucketName, string jsonCrePath)
23        {
24            BucketName = bucketName;
25            JsonCrePath = jsonCrePath;
26            InitializeStorageClient();
27        }
28
29        private void InitializeStorageClient()
30        {
31            try
32            {
33                GoogleCredential credential;
34                using (var jsonStream = new FileStream(JsonCrePath, FileMode.Open, FileAccess.Read, FileShare.Read))
35                {
36                    credential = GoogleCredential.FromStream(jsonStream);
37                }
38
39                storageClient = StorageClient.Create(credential);
40            }
41            catch (Exception ex)
42            {
43                Debug.LogError($"GCP Cloud Storage: Error initializing storage client: {ex.Message}");
44            }
45        }
46
47        public async void UploadObject(string localFilePath, string remoteFilePath, Action<double> progressAction)
48        {
49            await UploadFile(localFilePath, remoteFilePath, progressAction);
50        }
51
52        public async void UploadObjectByUrl(string fileUrl, string remoteFilePath, Action<double> progressAction)
53        {
54            await UploadFromUrl(fileUrl, remoteFilePath, progressAction);
55        }
56
57        private async Task UploadFile(string localFilePath, string remoteFileName, Action<double> progressAction)
58        {
59            try
60            {
61                await using var fileStream = new FileStream(localFilePath, FileMode.Open, FileAccess.Read);
62                await UploadStream(fileStream, remoteFileName, progressAction);
63            }
64            catch (Exception ex)
65            {
66                Debug.LogError($"GCP Cloud Storage: Error uploading file: {ex.Message}");
67            }
68        }
69
70        private async Task UploadFromUrl(string url, string remoteFileName, Action<double> progressAction)
71        {
72            using var www = UnityWebRequest.Get(url);
73            www.SendWebRequest();
74
75            while (!www.isDone)
76            {
77                await Task.Yield();
78            }
79
80            if (www.result != UnityWebRequest.Result.Success)
81            {
82                throw new Exception($"GCP Cloud Storage: Failed to download file: {www.error}");
83            }
84
85            using var memoryStream = new MemoryStream(www.downloadHandler.data);
86            await UploadStream(memoryStream, remoteFileName, progressAction);
87        }
88
89        private async Task UploadStream(Stream stream, string remoteFileName, Action<double> progressAction)
90        {
91            var progress = new Progress<IUploadProgress>(p =>
92            {
93                var percentComplete = (double)p.BytesSent / stream.Length * 100;
94
95                Debug.Log($"GCP Cloud Storage Upload Progress: " +
96                          $"{percentComplete:F2}% ({p.BytesSent}/{stream.Length} bytes)");
97
98                // Update UI Action on main thread
99                if (progressAction != null)
100                {
101                    UnityMainThreadDispatcher.Instance().Enqueue(() => { progressAction?.Invoke(percentComplete); });
102                }
103            });
104
105            var uploadObjectOptions = new UploadObjectOptions
106            {
107                ChunkSize = UploadObjectOptions.MinimumChunkSize
108            };
109
110            await storageClient.UploadObjectAsync(
111                BucketName,
112                remoteFileName,
113                null,
114                stream,
115                options: uploadObjectOptions,
116                progress: progress
117            );
118
119            Debug.Log($"GCP Cloud Storage: Success Uploaded {remoteFileName} to {BucketName}.");
120        }
121    }
122}

1
2using System.IO;
3using UnityEngine;
4using UnityEngine.UI;
5
6namespace YFrame.API.Google.CloudStorage.Scene
7{
8    public class CloudStorageView : MonoBehaviour
9    {
10        public string bucketName = "your-bucket-name";
11        public string jsonKeyFilePath = "path-to-your-service-account-json-key-file";
12
13        [Header("File Upload UI")] 
14        public Dropdown UploadTypeDropdown; 
15        public Button UploadBtn;
16        public Text UploadProgressText;
17        public InputField FileInputField;
18        public InputField RemoteFileNameInputField;
19
20        private ICloudStorage CloudStorage = new CStorageImp();
21
22        private void Start()
23        {
24            CloudStorage.Initialize(bucketName,  Path.Combine(Application.streamingAssetsPath, jsonKeyFilePath));
25            UploadBtn.onClick.AddListener(UploadBtnOnClick);
26        }
27
28        private void UploadBtnOnClick()
29        {
30            switch (UploadTypeDropdown.value)
31            {
32                // Streaming Local File
33                case 0:
34                {
35                    var filePath = Path.Combine(Application.streamingAssetsPath, FileInputField.text);
36                    CloudStorage.UploadObject(filePath, RemoteFileNameInputField.text, UpdateProgressText);
37                    return;
38                }
39                // Upload By URL
40                case 1:
41                {
42                    CloudStorage.UploadObjectByUrl(FileInputField.text, RemoteFileNameInputField.text, UpdateProgressText);
43                    break;
44                }
45            }
46        }
47
48        private void UpdateProgressText(double progress)
49        {
50            UploadProgressText.text = $"Upload Progress: {progress:F2}";
51        }
52    }
53}