@@ -16,41 +16,87 @@ export default class Client extends OpenApi {
1616 this._endpoint = this.getEndpoint("esa", this._regionId, this._endpointRule, this._network, this._suffix, this._endpointMap, this._endpoint);
1717 }
1818
19- async _postOSSObject(bucketName: string, form: {[key: string]: any}): Promise<{[key: string]: any}> {
20- let request_ = new $dara.Request();
21- let boundary = $dara.Form.getBoundary();
22- request_.protocol = "HTTPS";
23- request_.method = "POST";
24- request_.pathname = `/`;
25- request_.headers = {
26- host: String(form["host"]),
27- date: OpenApiUtil.getDateUTCString(),
28- 'user-agent': OpenApiUtil.getUserAgent(""),
29- };
30- request_.headers["content-type"] = `multipart/form-data; boundary=${boundary}`;
31- request_.body = $dara.Form.toFileForm(form, boundary);
32- let response_ = await $dara.doAction(request_);
33-
34- let respMap : {[key: string]: any} = null;
35- let bodyStr = await $dara.Stream.readAsString(response_.body);
36- if ((response_.statusCode >= 400) && (response_.statusCode < 600)) {
37- respMap = $dara.XML.parseXml(bodyStr, null);
38- let err = respMap["Error"];
39- throw new $OpenApi.ClientError({
40- code: String(err["Code"]),
41- message: String(err["Message"]),
42- data: {
43- httpCode: response_.statusCode,
44- requestId: String(err["RequestId"]),
45- hostId: String(err["HostId"]),
46- },
47- });
48- }
49-
50- respMap = $dara.XML.parseXml(bodyStr, null);
51- return {
52- ...respMap,
53- };
19+ async _postOSSObject(bucketName: string, form: {[key: string]: any}, runtime: $dara.RuntimeOptions): Promise<{[key: string]: any}> {
20+ let _runtime: { [key: string]: any } = {
21+ key: runtime.key || this._key,
22+ cert: runtime.cert || this._cert,
23+ ca: runtime.ca || this._ca,
24+ readTimeout: runtime.readTimeout || this._readTimeout,
25+ connectTimeout: runtime.connectTimeout || this._connectTimeout,
26+ httpProxy: runtime.httpProxy || this._httpProxy,
27+ httpsProxy: runtime.httpsProxy || this._httpsProxy,
28+ noProxy: runtime.noProxy || this._noProxy,
29+ socks5Proxy: runtime.socks5Proxy || this._socks5Proxy,
30+ socks5NetWork: runtime.socks5NetWork || this._socks5NetWork,
31+ maxIdleConns: runtime.maxIdleConns || this._maxIdleConns,
32+ retryOptions: this._retryOptions,
33+ ignoreSSL: runtime.ignoreSSL || false,
34+ tlsMinVersion: this._tlsMinVersion,
35+ }
36+
37+ let _retriesAttempted = 0;
38+ let _lastRequest = null, _lastResponse = null;
39+ let _context = new $dara.RetryPolicyContext({
40+ retriesAttempted: _retriesAttempted,
41+ });
42+ while ($dara.shouldRetry(_runtime['retryOptions'], _context)) {
43+ if (_retriesAttempted > 0) {
44+ let _backoffTime = $dara.getBackoffDelay(_runtime['retryOptions'], _context);
45+ if (_backoffTime > 0) {
46+ await $dara.sleep(_backoffTime);
47+ }
48+ }
49+
50+ _retriesAttempted = _retriesAttempted + 1;
51+ try {
52+ let request_ = new $dara.Request();
53+ let boundary = $dara.Form.getBoundary();
54+ request_.protocol = "HTTPS";
55+ request_.method = "POST";
56+ request_.pathname = `/`;
57+ request_.headers = {
58+ host: String(form["host"]),
59+ date: OpenApiUtil.getDateUTCString(),
60+ 'user-agent': OpenApiUtil.getUserAgent(""),
61+ };
62+ request_.headers["content-type"] = `multipart/form-data; boundary=${boundary}`;
63+ request_.body = $dara.Form.toFileForm(form, boundary);
64+ _lastRequest = request_;
65+ let response_ = await $dara.doAction(request_, _runtime);
66+ _lastResponse = response_;
67+
68+ let respMap : {[key: string]: any} = null;
69+ let bodyStr = await $dara.Stream.readAsString(response_.body);
70+ if ((response_.statusCode >= 400) && (response_.statusCode < 600)) {
71+ respMap = $dara.XML.parseXml(bodyStr, null);
72+ let err = respMap["Error"];
73+ throw new $OpenApi.ClientError({
74+ code: String(err["Code"]),
75+ message: String(err["Message"]),
76+ data: {
77+ httpCode: response_.statusCode,
78+ requestId: String(err["RequestId"]),
79+ hostId: String(err["HostId"]),
80+ },
81+ });
82+ }
83+
84+ respMap = $dara.XML.parseXml(bodyStr, null);
85+ return {
86+ ...respMap,
87+ };
88+ } catch (ex) {
89+ _context = new $dara.RetryPolicyContext({
90+ retriesAttempted : _retriesAttempted,
91+ httpRequest : _lastRequest,
92+ httpResponse : _lastResponse,
93+ exception : ex,
94+ });
95+ continue;
96+ }
97+ }
98+
99+ throw $dara.newUnretryableError(_context);
54100 }
55101
56102 getEndpoint(productId: string, regionId: string, endpointRule: string, network: string, suffix: string, endpointMap: {[key: string ]: string}, endpoint: string): string {
@@ -569,7 +615,7 @@ export default class Client extends OpenApi {
569615 file: fileObj,
570616 success_action_status: "201",
571617 };
572- await this._postOSSObject(authResponseBody["Bucket"], ossHeader);
618+ await this._postOSSObject(authResponseBody["Bucket"], ossHeader, runtime );
573619 batchDeleteKvWithHighCapacityReq.url = `http://${authResponseBody["Bucket"]}.${authResponseBody["Endpoint"]}/${authResponseBody["ObjectKey"]}`;
574620 }
575621
@@ -915,7 +961,7 @@ export default class Client extends OpenApi {
915961 file: fileObj,
916962 success_action_status: "201",
917963 };
918- await this._postOSSObject(authResponseBody["Bucket"], ossHeader);
964+ await this._postOSSObject(authResponseBody["Bucket"], ossHeader, runtime );
919965 batchPutKvWithHighCapacityReq.url = `http://${authResponseBody["Bucket"]}.${authResponseBody["Endpoint"]}/${authResponseBody["ObjectKey"]}`;
920966 }
921967
@@ -7841,6 +7887,52 @@ export default class Client extends OpenApi {
78417887 return await this.exportRecordsWithOptions(request, runtime);
78427888 }
78437889
7890+ /**
7891+ * 获取架构文件套餐使用情况
7892+ *
7893+ * @param request - GetApiSchemaUsageRequest
7894+ * @param runtime - runtime options for this request RuntimeOptions
7895+ * @returns GetApiSchemaUsageResponse
7896+ */
7897+ async getApiSchemaUsageWithOptions(request: $_model.GetApiSchemaUsageRequest, runtime: $dara.RuntimeOptions): Promise<$_model.GetApiSchemaUsageResponse> {
7898+ request.validate();
7899+ let query = { };
7900+ if (!$dara.isNull(request.siteId)) {
7901+ query["SiteId"] = request.siteId;
7902+ }
7903+
7904+ if (!$dara.isNull(request.siteVersion)) {
7905+ query["SiteVersion"] = request.siteVersion;
7906+ }
7907+
7908+ let req = new $OpenApiUtil.OpenApiRequest({
7909+ query: OpenApiUtil.query(query),
7910+ });
7911+ let params = new $OpenApiUtil.Params({
7912+ action: "GetApiSchemaUsage",
7913+ version: "2024-09-10",
7914+ protocol: "HTTPS",
7915+ pathname: "/",
7916+ method: "POST",
7917+ authType: "AK",
7918+ style: "RPC",
7919+ reqBodyType: "formData",
7920+ bodyType: "json",
7921+ });
7922+ return $dara.cast<$_model.GetApiSchemaUsageResponse>(await this.callApi(params, req, runtime), new $_model.GetApiSchemaUsageResponse({}));
7923+ }
7924+
7925+ /**
7926+ * 获取架构文件套餐使用情况
7927+ *
7928+ * @param request - GetApiSchemaUsageRequest
7929+ * @returns GetApiSchemaUsageResponse
7930+ */
7931+ async getApiSchemaUsage(request: $_model.GetApiSchemaUsageRequest): Promise<$_model.GetApiSchemaUsageResponse> {
7932+ let runtime = new $dara.RuntimeOptions({ });
7933+ return await this.getApiSchemaUsageWithOptions(request, runtime);
7934+ }
7935+
78447936 /**
78457937 * Queries the available specifications of cache reserve instances.
78467938 *
@@ -14597,7 +14689,7 @@ export default class Client extends OpenApi {
1459714689 file: fileObj,
1459814690 success_action_status: "201",
1459914691 };
14600- await this._postOSSObject(authResponseBody["Bucket"], ossHeader);
14692+ await this._postOSSObject(authResponseBody["Bucket"], ossHeader, runtime );
1460114693 putKvWithHighCapacityReq.url = `http://${authResponseBody["Bucket"]}.${authResponseBody["Endpoint"]}/${authResponseBody["ObjectKey"]}`;
1460214694 }
1460314695
@@ -19149,7 +19241,7 @@ export default class Client extends OpenApi {
1914919241 file: fileObj,
1915019242 success_action_status: "201",
1915119243 };
19152- await this._postOSSObject(authResponseBody["Bucket"], ossHeader);
19244+ await this._postOSSObject(authResponseBody["Bucket"], ossHeader, runtime );
1915319245 uploadFileReq.url = `http://${authResponseBody["Bucket"]}.${authResponseBody["Endpoint"]}/${authResponseBody["ObjectKey"]}`;
1915419246 }
1915519247
0 commit comments