- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我想使用计时器触发的 Azure Function 来生成多个 axios 后调用,以更改多个 CosmosDB 集合的吞吐量设置。
根据日志,以下代码将启动(即出现“[信息]函数已启动”消息),但随后将不再显示任何日志记录,并且该函数将以状态代码结束 202 已接受。
我怀疑问题是由我处理 axios Promise 的方式引起的,但经过多次尝试后,我转向 Stackoverflow 寻求帮助。
任何帮助将不胜感激。
const axios = require("axios");
const azure = require("azure-storage");
const functionURL = "https://<redacted>.azurewebsites.net/api/ChangeRU?code=<redacted>"
// Update Offer for Collection
function updateOffer_for_Collection_RESTCall(
environment,
database,
collection,
newRU
) {
context.log(`\nUpdate throughput for collection (${collection}) in database (${database}) of environment (${environment}) to: ${newRU}`);
// Execute REST call
const url = functionURL + "&env=" + environment + "&database=" + database + "&collection=" + collection + "&ru=" + newRU;
context.log(`url = ${url}`);
return url;
}
module.exports = function (context, myTimer) {
var timeStamp = new Date().toISOString();
context.log('Scale down job started:', timeStamp);
if (myTimer.isPastDue) {
context.log('Scale down job is running late!');
}
var collectionTableService = azure.createTableService("<storageaccount>", "<redacted>");
const query = new azure.TableQuery()
.top(2)
.where('PartitionKey eq ?', 'DBCollections');
context.log('Query created...');
collectionTableService.queryEntities('DBCollections', query, null, function (error, result, response) {
if (!error) {
// result.entries contains entities matching the query
const collections = result.entries;
let axiosArray = [];
for (let collection of collections) {
context.log("Collection: " + JSON.stringify(collection) + "\n");
// Process collection
let url = updateOffer_for_Collection_RESTCall(collection.environment._, collection.database._, collection.collection._, 400);
let newPromise = axios({
method: 'post',
url: url,
data: {}
});
axiosArray.push(newPromise);
};
axios
.all(axiosArray)
.then(
function (results) {
let temp = results.map(r => r.data);
context.log('submitted all axios calls');
})
.catch(error => { });
context.done();
} else {
context.log('Error retrieving records from table DBCollections: ' + error);
context.done();
}
});
};
最佳答案
在过去的几天里对 Javascript Promise 有了更好的理解,我准备好回答我自己的问题了:-)
考虑以下重写:
// This Azure Function will change the request units setting of a number of Cosmos DB database collections at CSP <redacted>
// Use https://github.com/axios/axios as a REST client
const axios = require("axios");
const azure = require("azure-storage");
const functionURL =
"https://<redacted>.azurewebsites.net/api/<redacted>?code=<redacted>";
module.exports = function (context, myTimer) {
context.log("Going in...");
function asyncPostURL(url) {
return new Promise((resolve, reject) => {
axios.post(url)
.then(function (response) {
context.log(`POST response: status=${response.status}, data=${response.data}`);
resolve(response.data);
})
.catch(function (error) {
context.log(error);
reject(error);
});
});
}
// Create POST url to update offer for collection
function create_url(record) {
const environment = record.environment._;
const database = record.database._;
const collection = record.collection._;
const newRU = record.scaleupRU._;
context.log(
`\nUpdate throughput for collection (${collection}) in database (${database}) of environment (${environment}) to: ${newRU}`
);
// Create POST url
const url =
functionURL +
"&env=" +
environment +
"&database=" +
database +
"&collection=" +
collection +
"&ru=" +
newRU;
context.log(`url: ${url}`);
return url;
}
function post_urls(arr, final, context) {
return arr.reduce((promise, record) => {
return promise
.then(result => {
let url = create_url(record);
context.log(`url: ${url}.`);
return asyncPostURL(url).then(result => final.push(result));
})
.catch(error => {
context.log(error);
});
}, Promise.resolve());
}
var timeStamp = new Date().toISOString();
context.log("Scale down job started:", timeStamp);
if (myTimer.isPastDue) {
context.log("Scale down job is running late!");
}
var collectionTableService = azure.createTableService(
"pbscsptoolsstorage",
"<redacted>"
);
const query = new azure.TableQuery()
//.top(2)
.where("PartitionKey eq ?", "DBCollections");
context.log("Query created...");
const get_collections = tbl =>
new Promise((resolve, reject) => {
collectionTableService.queryEntities(tbl, query, null, function (
error,
result,
response
) {
if (!error) {
context.log(`# entries: ${result.entries.length}`);
resolve(result.entries);
} else {
reject(error);
}
});
});
var final = [];
get_collections("<redacted>").then(
collections => {
context.log(`# collections: ${collections.length}`);
post_urls(collections, final, context).then(() => context.log(`FINAL RESULT is ${final}`))
.then(() => context.done());
},
error => {
context.log("Promise get_collections failed: ", error)
.then(() => context.done());
}
)
};
关于javascript - 计时器触发Azure Function开始但未结束?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51037617/
这个问题已经有答案了: jQuery trigger click vs click ()? (3 个回答) 已关闭 5 年前。 我无法区分 trigger('click')与 trigger('cli
我正在运行 VS 2008 和 .NET 3.5 SP1。 我想在 HttpModule 中实现命中跟踪在我的 ASP.NET 应用程序中。很简单,我想。然而,BeginRequest我的事件 Htt
这是一段代码,我收到以下错误 #1064 - You have an error in your SQL syntax; check the manual that corresponds to yo
有没有办法用任意增量触发滚轮事件。就像 jQuery 对“点击”所做的那样: $('#selector').trigger('click'); 我需要类似的东西,只需一个滚轮即可: $('#selec
我正在尝试在配音数据库中触发时间。我想检查一下在不出现角色的电影配音中不能对角色进行配音。这是PDM: 和CDM 我是SQL的初学者,但我知道表“DUBBES”中应该有一些触发器。我试图做这样的事情,
这个问题已经有答案了: jquery programmatically click on new dom element (3 个回答) 已关闭 6 年前。 我有一个 jQuery 事件定义如下: $
主菜单的点击代码适用于类更改,但不适用于子菜单...当单击食物或鞋子等子菜单项时,它不会触发警报命令...事实上,悬停非常适合子菜单但不是活跃的 HTML
问题非常简单: $('#btn1').click(function(event){ alert( "pageX: " + event.pageX + "\npa
我使用 Spring 的调度程序 (@EnableScheduling) 并具有以下 @Scheduled 方法,该方法每分钟调用一次: @Component public class Schedul
错误 SQL 查询:文档 CREATE TRIGGER `triggers_div` AFTER INSERT ON `produits` FOR EACH ROW BEGIN INSERT INTO
我想在插入另一个表时填充表中的一些列值,并为特定列设置条件。我使用触发器: CREATE TRIGGER inserttrigger AFTER INSERT ON table1 FOR EACH R
我可以在 5.6 MySQL 环境中使用一些关于触发器的指导。我想创建一个触发器,如果发现具有相同速度的电脑的价格较低,则该触发器会停止更新。 架构是产品(制造商、型号、类型)PC(型号、速度、内
背景:我们有一个 completed_flag,默认为 0,当有人完成调查时更新为 1。我想记录这次更新发生的时间戳 在编写了这个触发器/函数以在标志从 0 触发到 1 时更新时间戳后,我怀疑我这样做
数据库中有两个表 KistStatus和 LastKistStatus .后者将保存 KistStatus 的所有“最新”值。 . KistStatus有大约 174.000 条记录,LastKist
我正在开发一个使用 APNS 的 iPhone 应用程序。我很清楚实现 APNS、创 build 备 token 的过程,等等等等……我不知道如何通过 Web 服务从提供商端触发和启动 APNS。任何
我有这个 javascript,当数量更改时会触发 update_cart... jQuery('div.woocommerce').on('change', '.qty', function
当我单击任何按钮时,click 事件不会被触发。艰难的是,我使用 $("div").on("click", "button", function () { 让它工作,但我想看到它使用 .class 工
如何在我的代码中触发 Android onCreateOptionsMenu 函数,即无需用户单击手机上的选项菜单按钮? 最佳答案 Activity.openOptionsMenu(); 就可以了 关
我将表单包装在 中然后我设置 list android:windowSoftInputMode="adjustResize" (默认 react native )。现在,当我用手指触摸事件手动聚焦一
我有一个 Android 编程问题。使用下面的代码我想验证一个字符串匹配。它验证正常,但 LogCat 显示 TextWatcher 方法在每次击键时触发两次,我不明白为什么。我希望每次击键只触发一次
我是一名优秀的程序员,十分优秀!