var config = {
  // Tencent Cloud 키를 획득합니다. 제한된 권한을 가진 서브 사용자의 키 사용을 권장합니다. https://console.tencentcloud.com/cam/capi
  secretId: process.env.COS_SECRET_ID,
  secretKey: process.env.COS_SECRET_KEY,
  // 키 유효 기간
  durationSeconds: 1800,
  // 여기에 버킷 및 리전을 입력합니다. 예: test-1250000000, ap-guangzhou
  bucket: process.env.PERSIST_BUCKET,
  region: process.env.PERSIST_BUCKET_REGION,
  // 제한된 업로드 확장자
  extWhiteList: ['jpg', 'jpeg', 'png', 'gif', 'bmp'],
};

npm install

node app.js

/// 직접 업로드 url 및 서명 등 획득
/// @param ext 파일 확장자. 직접 업로드 시 서버드에서 확장자에 따라 cos key 생성
/// @return 직접 업로드 url 및 서명 등
static Future<Map<String, dynamic>> getStsDirectSign(String ext) async {
  Dio dio = Dio();
  //직접 업로드 서명 비즈니스 서버 url(실제 환경에서는 정식 직접 업로드 서명 비즈니스 url로 교체해 주세요)
  //직접 업로드 서명 비즈니스 서버 코드 예제는 https://github.com/tencentyun/cos-demo/blob/main/server/direct-sign/nodejs/app.js를 참고하십시오.
  //10.91.22.16은 직접 업로드 서명 비즈니스 서버의 주소입니다. 예를 들어 위의 node 서비스와 같이, 직접 업로드 서명 비즈니스 서버에 접근할 수 있는 url이면 됩니다.
  Response response = await dio.get('http://10.91.22.16:3000/sts-direct-sign',
      queryParameters: {'ext': ext});
  if (response.statusCode == 200) {
    if (kDebugMode) {
      print(response.data);
    }
    if (response.data['code'] == 0) {
      return response.data['data'];
    } else {
      throw Exception(
          'getStsDirectSign error code: ${response.data['code']}, error message: ${response.data['message']}');
    }
  } else {
    throw Exception(
        'getStsDirectSign HTTP error code: ${response.statusCode}');
  }
}

/// 파일 업로드
/// @param filePath 파일 경로
/// @param progressCallback 진행 상태 콜백
static Future<void> upload(String filePath, ProgressCallback progressCallback) async {
  String ext = path.extension(filePath).substring(1);
  Map<String, dynamic> directTransferData;
  try {
    directTransferData = await getStsDirectSign(ext);
  } catch (err) {
    if (kDebugMode) {
      print(err);
    }
    throw Exception("getStsDirectSign fail");
  }
  String cosHost = directTransferData['cosHost'];
  String cosKey = directTransferData['cosKey'];
  String authorization = directTransferData['authorization'];
  String securityToken = directTransferData['securityToken'];
  String url = 'https://$cosHost/$cosKey';
  File file = File(filePath);
  Options options = Options(
    method: 'PUT',
    headers: {
      'Content-Length': await file.length(),
      'Content-Type': 'application/octet-stream',
      'Authorization': authorization,
      'x-cos-security-token': securityToken,
      'Host': cosHost,
    },
  );
  try {
    Dio dio = Dio();
    Response response = await dio.put(url,
        data: file.openRead(),
        options: options, onSendProgress: (int sent, int total) {
          double progress = sent / total;
          if (kDebugMode) {
            print('Progress: ${progress.toStringAsFixed(2)}');
          }
          progressCallback(sent, total);
        });
    if (response.statusCode == 200) {
      if (kDebugMode) {
        print('업로드 성공');
      }
    } else {
      throw Exception("업로드 실패 ${response.statusMessage}");
    }
  } catch (error) {
    if (kDebugMode) {
      print('Error: $error');
    }
    throw Exception("업로드 실패 ${error.toString()}");
  }
}

/// 직접 업로드 url 및 서명 등 획득
/// @param ext 파일 확장자. 직접 업로드 시 서버드에서 확장자에 따라 cos key 생성
/// @return 직접 업로드 url 및 서명 등
static Future<Map<String, dynamic>> _getStsDirectSign(String ext) async {
  HttpClient httpClient = HttpClient();
 //직접 업로드 서명 비즈니스 서버 url(정식 환경에서는 정식 직접 업로드 서명 비즈니스 url로 교체해 주세요)
  //직접 업로드 서명 비즈니스 서버 코드 예제는 https://github.com/tencentyun/cos-demo/blob/main/server/direct-sign/nodejs/app.js를 참고하십시오.
 //10.91.22.16은 직접 업로드 서명 비즈니스 서버의 주소입니다. 예를 들어 위의 node 서비스와 같이, 직접 업로드 서명 비즈니스 서버에 접근할 수 있는 url이면 됩니다.
  HttpClientRequest request = await httpClient
      .getUrl(Uri.parse("http://10.91.22.16:3000/sts-direct-sign?ext=$ext"));
  HttpClientResponse response = await request.close();
  String responseBody = await response.transform(utf8.decoder).join();
  if (response.statusCode == 200) {
    Map<String, dynamic> json = jsonDecode(responseBody);
    if (kDebugMode) {
      print(json);
    }
    httpClient.close();
    if (json['code'] == 0) {
      return json['data'];
    } else {
      throw Exception(
          'getStsDirectSign error code: ${json['code']}, error message: ${json['message']}');
    }
  } else {
    httpClient.close();
    throw Exception(
        'getStsDirectSign HTTP error code: ${response.statusCode}');
  }
}

/// 파일 업로드
/// @param filePath 파일 경로
/// @param progressCallback 진행 상태 콜백
static Future<void> upload(String filePath, ProgressCallback progressCallback) async {
  // 직접 업로드 서명 등 정보 획득
  String ext = path.extension(filePath).substring(1);
  Map<String, dynamic> directTransferData;
  try {
    directTransferData = await _getStsDirectSign(ext);
  } catch (err) {
    if (kDebugMode) {
      print(err);
    }
    throw Exception("getStsDirectSign fail");
  }

  String cosHost = directTransferData['cosHost'];
  String cosKey = directTransferData['cosKey'];
  String authorization = directTransferData['authorization'];
  String securityToken = directTransferData['securityToken'];
  String url = 'https://$cosHost/$cosKey';

  File file = File(filePath);
  int fileSize = await file.length();
  HttpClient httpClient = HttpClient();
  HttpClientRequest request = await httpClient.putUrl(Uri.parse(url));
  request.headers.set('Content-Type', 'application/octet-stream');
  request.headers.set('Content-Length', fileSize.toString());
  request.headers.set('Authorization', authorization);
  request.headers.set('x-cos-security-token', securityToken);
  request.headers.set('Host', cosHost);
  request.contentLength = fileSize;
  Stream<List<int>> stream = file.openRead();
  int bytesSent = 0;
  stream.listen(
        (List<int> chunk) {
      bytesSent += chunk.length;
      double progress = bytesSent / fileSize;
      if (kDebugMode) {
        print('Progress: ${progress.toStringAsFixed(2)}');
      }
      progressCallback(bytesSent, fileSize);
      request.add(chunk);
    },
    onDone: () async {
      HttpClientResponse response = await request.close();
      if (response.statusCode == 200) {
        if (kDebugMode) {
          print('업로드 성공');
        }
      } else {
        throw Exception("업로드 실패 $response");
      }
    },
    onError: (error) {
      if (kDebugMode) {
        print('Error: $error');
      }
      throw Exception("업로드 실패 ${error.toString()}");
    },
    cancelOnError: true,
  );
}