var config = {// Get Tencent Cloud Key, recommend using a Sub-user key with limited permissions https://console.tencentcloud.com/cam/capisecretId: process.env.COS_SECRET_ID,secretKey: process.env.COS_SECRET_KEY,// key validity perioddurationSeconds: 1800,// Fill in the bucket and region here, for example: test-1250000000, ap-guangzhoubucket: process.env.PERSIST_BUCKET,region: process.env.PERSIST_BUCKET_REGION,// Upload extension limitextWhiteList: ['jpg', 'jpeg', 'png', 'gif', 'bmp'],};
npm install
node app.js
import http from '@ohos.net.http';/**Get the direct upload url and signature** @param ext File suffix. The backend generates a cos key based on the suffix for direct upload.* @returns Direct upload url and signature*/public static async getStsDirectSign(ext: string): Promise<Object> {// Each httpRequest corresponds to an HTTP request task and cannot be reusedlet httpRequest = http.createHttp();//Direct upload signature business server url (official environment, replace with official direct upload signature business url)// For server-side code example of direct upload signature business, see: https://github.com/tencentyun/cos-demo/blob/main/server/direct-sign/nodejs/app.jslet url = "http://127.0.0.1:3000/sts-direct-sign?ext=" + ext;try {let httpResponse = await httpRequest.request(url, { method: http.RequestMethod.GET });if (httpResponse.responseCode == 200) {let result = JSON.parse(httpResponse.result.toString())if (result.code == 0) {return result.data;} else {console.info(`getStsDirectSign error code: ${result.code}, error message: ${result.message}`);}} else {console.info("getStsDirectSign HTTP error code: " + httpResponse.responseCode);}} catch (err) {console.info("getStsDirectSign Error sending GET request: " + JSON.stringify(err));} finally {// When the request is complete, call destroy to terminate.httpRequest.destroy();}return null;}
import http from '@ohos.net.http';import promptAction from '@ohos.promptAction'import fs from '@ohos.file.fs';import request from '@ohos.request';import common from '@ohos.app.ability.common';import { MediaBean } from '../bean/MediaBean';import { MediaHelper } from './MediaHelper';/*** Upload files (implemented via uploadTask)* @param context context* @param media Media file*/public static async uploadFileByTask(context: common.Context, media: MediaBean, progressCallback: (uploadedSize: number, totalSize: number) => void) {// Get the direct upload signature and datalet ext = MediaHelper.getFileExtension(media.fileName);let directTransferData: any = await UploadHelper.getStsDirectSign(ext);if (directTransferData == null) {promptAction.showToast({ message: 'getStsDirectSign fail' });return;}// Upload information returned by the serverlet cosHost: String = directTransferData.cosHost;let cosKey: String = directTransferData.cosKey;let authorization: String = directTransferData.authorization;let securityToken: String = directTransferData.securityToken;// Generate the uploaded urllet url = `https://${cosHost}/${cosKey}`;try {// Copy the uri file to cacheDir (because request.uploadFile only accepts internal: paths)let file = await fs.open(media.fileUri, fs.OpenMode.READ_ONLY);let destPath = context.cacheDir + "/" + media.fileName;await fs.copyFile(file.fd, destPath);let realuri = "internal://cache/" + destPath.split("cache/")[1];let uploadConfig = {url: url,header: {"Content-Type": "application/octet-stream","Authorization": authorization,"x-cos-security-token": securityToken,"Host": cosHost},method: "PUT",files: [{ filename: media.fileName, name: "file", uri: realuri, type: ext }],data: []};// Start uploadinglet uploadTask = await request.uploadFile(context, uploadConfig)uploadTask.on('progress', progressCallback);let upCompleteCallback = (taskStates) => {for (let i = 0; i < taskStates.length; i++) {promptAction.showToast({ message: 'upload succeeded' });console.info("upOnComplete taskState:" + JSON.stringify(taskStates[i]));}};uploadTask.on('complete', upCompleteCallback);let upFailCallback = (taskStates) => {for (let i = 0; i < taskStates.length; i++) {promptAction.showToast({ message: 'upload failed' });console.info("upOnFail taskState:" + JSON.stringify(taskStates[i]));}};uploadTask.on('fail', upFailCallback);} catch (err) {console.info("uploadFile Error sending PUT request: " + JSON.stringify(err));promptAction.showToast({ message: "uploadFile Error sending PUT request: " + JSON.stringify(err) });}}
Feedback