Async/await在继续之前不会等待数据库查询
Async/await是一种用于处理异步操作的语法糖，它可以使代码更加简洁和易读。在云计算领域中，Async/await常用于处理数据库查询等耗时操作。
Async/await的工作原理是基于Promise对象。当使用Async关键字声明一个函数时，该函数将自动返回一个Promise对象。在函数内部，可以使用await关键字来等待一个Promise对象的解决（resolved）或拒绝（rejected）状态。
对于数据库查询这样的异步操作，可以使用Async/await来实现等待查询结果返回的功能。在代码中，可以使用await关键字等待数据库查询的结果，而不需要使用回调函数或者Promise的then方法。这样可以使代码更加简洁和易于理解。
Async/await的优势在于：
- 简洁易读：相比于传统的回调函数或Promise链式调用，Async/await可以使异步代码看起来更像同步代码，提高代码的可读性和可维护性。
- 错误处理：使用try/catch语法可以方便地捕获和处理异步操作中的错误，使错误处理更加直观和简单。
- 顺序控制：可以使用同步的方式编写异步操作，避免了回调地狱（callback hell）的问题，使代码逻辑更加清晰。
在云计算领域中，Async/await可以应用于各种场景，包括但不限于：
- 数据库操作：如查询、插入、更新等操作。
- 文件操作：如读取、写入、删除等操作。
- 网络请求：如HTTP请求、API调用等操作。
- 并发处理：如同时进行多个异步操作，并等待它们全部完成后再进行下一步操作。
腾讯云提供了一系列与云计算相关的产品，可以满足各种异步操作的需求。以下是一些推荐的腾讯云产品和产品介绍链接地址：
- 云数据库 TencentDB：https://cloud.tencent.com/product/cdb
- 对象存储 COS：https://cloud.tencent.com/product/cos
- 云函数 SCF：https://cloud.tencent.com/product/scf
- 弹性容器实例 TKE：https://cloud.tencent.com/product/tke
- 弹性MapReduce EMR：https://cloud.tencent.com/product/emr
通过使用这些腾讯云产品，可以实现异步操作的高效处理，并提升云计算应用的性能和可靠性。
相关·内容
据我所知，如果在异步方法中没有等待关键字，那么方法将继续而不等待任务，因此删除等待关键字应该会继续，并立即在控制台中显示Boom消息，而不是等待运行方法完成。然而，当我在Main中删除await时：
await new Runner().Run(date);
word Boom仍在等待，并在运行完成后显示在控制台中。有谁能解释一下吗？我知道这一点，因为在SomeFunction中有一个数据库连接，它试图连接，几秒钟后给控制台错误，我总是首先看到错误，然后到达Boom行。
public static async Task Main()
{
Task aa = new Runner().
浏览 0提问于2018-10-26得票数 0
2回答
我尝试在返回函数之前使用await来完成数据库查询，但由于某些原因，我的方法似乎不起作用。
似乎在await返回解析的Promise之前，函数就返回了。
var returnAfterReading = async () => {
let myEntityJSONConst = {
myEntity : {}
}
myEntityJSONConst["myEntity"] = await dbQueryPromise();
return myEntityJSONConst;
}
console.log(JSON.stri
浏览 0提问于2019-08-08得票数 1
1回答
在有关异步web api 2操作的一些文章中，我发现了以下代码，这些代码演示了如何在Web 2中实现异步操作：
public class UserController : ApiController
{
ApiSecurityEntities _db = new ApiSecurityEntities();
public async Task<IHttpActionResult> Delete(Int32 Id)
{
var record = await _
浏览 3提问于2017-05-11得票数 0
回答已采纳
1回答
我正在经历一个问题，我确信，这与异步/等待相关。所以，通过编写这段代码，我想要实现的是，我已经创建了一个嵌入，它有两个按钮，“已批准”和“拒绝”(这部分代码不包括在上面)。因此，我想得到的是，如果用户按下“批准”按钮，approveChoice变量将被设置为“已批准”，否则-“拒绝”。我已经制作了这个if (await approvalChoice != "approved") return;，所以如果这个值没有被批准，代码就会停止执行。但是即使使用“等待”，"approvalChoice“变量也是未定义的(最后一行代码)
let senderID = interact
浏览 6提问于2022-03-19得票数 0
回答已采纳
1回答
我有两个异步方法：
Future<void> checkForUpdate() async {
InAppUpdate.checkForUpdate().then((info) {
setState(() {
_updateInfo = info;
print('@@@@@@@@@@@@@@@@@@@@@@@@@@$_updateInfo');
});
}).catchError((e) => _showError(
浏览 2提问于2019-11-13得票数 0
回答已采纳
1回答
所以我有：
async function functionName() {
return await new Promise( async (resolve, reject) => {
try {
//variables and such
for (let i = 0; i < results.length; i++) {
await geo.geocode('mapbox.places', address, async function (err, geoData) {
await db.q
浏览 1提问于2021-05-10得票数 0
回答已采纳
我在我的asp.net MVC web应用程序中有一个异步控制器。在控制器中有一个从数据库加载数据的方法，我通过添加" await“关键字作为前缀来等待这个方法。现在我的问题是，如果我有大量的数据要通过await方法加载，页面加载是否会停止或页面继续加载，直到方法返回数据。如果它将停止，那么它将如何显示返回的数据。谢谢。
浏览 1提问于2019-10-29得票数 0
我试图理解C#异步/等待，并观察到这种令人困惑的行为，其中异步方法不执行过去的Task.Delay调用。
考虑以下几点-
class Program
{
static void Main(string[] args)
{
Program p = new Program();
p.MakeBreakfast();
}
public async Task MakeBreakfast()
{
await BoilWater();
StartToaster();
PutTeainW
浏览 2提问于2019-04-27得票数 2
回答已采纳
2回答
我在使用aysnc和await执行API调用时遇到问题。我正在使用fetch方法调用Spring Boot服务，该服务在上传文件后返回一个JSON字符串。在获取上传文件数据的状态之前，下一个代码正在执行。帮我解决这个问题。下面是我写的代码： endProgressSimulation(uploadingFiles) {
this.setState(({ acceptedFiles }) => {
const updatedFiles = acceptedFiles.map(file => {
if (uplo
浏览 35提问于2019-09-13得票数 0
我看过一些关于async和await的文章，以及它们是如何工作的，但我还是有点困惑。假设我有两个async方法，我希望确保第二个方法在第一个方法完成后启动。例如，考虑这样的事情：
public async Task MyMethod(Item x)
{
await AddRequest(x); // 1. Add an item asynchronously
// make sure 2 starts after 1 completes
await GetAllRequest(); // 2. get all items a
浏览 6提问于2018-01-06得票数 1
回答已采纳
我有10个类似于以下功能的函数(数据库查询)：
async loadEmails(){
this.emails = await (EmailEntity as any).findAll(this.where)
}
async loadUrls(){
this.urls = await (UrlEntity as any).findAll(this.where)
}
我一个接一个地给他们打电话。
我想加快执行速度。
for(const i in toLoad){
let name = toLoad[i];
name =
浏览 2提问于2020-10-31得票数 0
回答已采纳
如果我在一个库中有这个
public async DoSomething()
{
await Foo();
}
然后，我将其称为lib.DoSomething().ConfigureAwait(false).GetAwaiter().GetResult()
这会不会给我带来同样的好处，就好像图书馆最初有
public async DoSomething()
{
await Foo().ConfigureAwait(false);
}
浏览 20提问于2018-02-14得票数 4
回答已采纳
1回答
这是我正在使用的示例代码。我想快速解析页面并将结果数据输入到数据库中。然而，在添加一行之后，我的代码运行速度明显变慢了。我知道这与数据库的工作有关。但我不知道该怎么解决它。
如果您对加速此代码有任何其他建议，我将非常感谢您的帮助。
import asyncpg
import asyncio
import aiohttp
from settings import URI, SQL, URLS
class Singleton(type):
_instances = {}
def __call__(cls, *args, **kwargs):
if cls no
浏览 16提问于2020-12-23得票数 0
我想使用下面代码中引用的insertIntoTable将数据插入到Oracle数据库表中；该函数无法工作，但如果没有它，查询就会按预期工作。 let connection;
var oracledb = require('oracledb');
(async function() {
try{
connection = await oracledb.getConnection({
user : 'demo7',
password : 'dbpass',
connectString : 'localho
浏览 89提问于2019-09-06得票数 0
回答已采纳
1回答
我正在开发一个网络应用程序，它接收来自websocket的数据，对其进行修改，并将其上传到数据服务。上传数据需要一些时间，我想隐藏这个延迟，一次上传几条消息。当上传完成后，我需要通过websocket发送一个确认。
我创建了一个工作队列来保存所有未完成的任务。这似乎很好，所以我还没有把它包括进去。但我的上传任务似乎在完成之前就完成了。这是一个修剪过的样品。
private async Task UploadDataAsync(string data, CancellationToken cancellationToken)
{
Task uploadTask = new Task(as
浏览 3提问于2020-03-12得票数 1
回答已采纳
1回答
等待多个异步函数并不能真正异步工作，例如，我期望下面的代码在大约6秒内运行，但它像同步代码一样运行，在10秒内执行。但是当我在asyncio.gather中尝试它时，它是在大约6秒内执行的。
有人能解释一下为什么会这样吗？
#Not working concurrently
async def async_sleep(n):
await asyncio.sleep(n+2)
await asyncio.sleep(n)
start_time = time.time()
asyncio.run(async_sleep(4))
end_time = time.time()
pr
浏览 0提问于2019-08-16得票数 10
1回答
我正在尝试使用异步，等待上传过程。我创建了一个小代码来查看它是否有效。
class Program
{
static void Main(string[] args)
{
for (int i = 0; i < 5; i++)
{
TestAsync().Wait();
}
}
public static async Task TestAsync()
{
await Task.Run(() => {
浏览 1提问于2015-05-27得票数 2
回答已采纳
2回答
我并不真正理解等待/异步机制(在dart中，但我想这个问题实际上与任何语言都相关)。我使用sqfentity库来管理一个小型数据库。
这个库提供了select().toList()函数，它将查询一些DB行并将其作为对象列表返回。
返回的函数实际上是返回一个未来，允许异步运行查询。
我正在使用本地DB，所以我并不真正关心访问时间问题，因此，一旦查询完成，我想编写一个返回列表的函数：
List<Event> get_list() async{
return await Event()
.select()
.toList()
}
问题是
浏览 1提问于2022-03-25得票数 -1
回答已采纳
1回答
我是异步编程的新手，我的问题可能看起来很傻。请有人解释一下在下面的伪代码示例中异步调用是如何工作的吗？
public async Task MyMethod()
{
while(true)
{
await Method1();
//do something in MyMethod
await Task.Delay(10000);
}
}
private async Task Method1()
{
//do something in Method1 before await
浏览 1提问于2017-09-07得票数 3
回答已采纳
我不知道为什么控制台日志中的变量结果在更新前返回状态
result[msisdn] = "customer exist"
它执行的代码本身，但是为什么在修改之前一直返回状态，我想我已经在我编写的所有异步代码上给了关键字。
code.ts
async migrateCustomerImageUseCase(request: ListCustomerForMigration, response: Response): Promise<any>{
const result = {} as any
const lists = request as
浏览 0提问于2021-11-25得票数 0
回答已采纳
我在文件login.js中有代码
const puppeteer = require('puppeteer');
const configpass = require("./config.json");
const login_helper = require("./login_helper");
(async () => {
const browser = await puppeteer.launch({
args: ["--no-sandbox"],
headless: false,
浏览 2提问于2019-11-29得票数 0
回答已采纳
3回答
我有一个由EntityFramework表示的数据库，我在异步任务中向它添加了一个元素。我的方法是这样简化的：
private async Task SavePoint(Point point)
{
using (var ctx = new testDBEntities())
{
ctx.Points.Add(point);
await ctx.SaveChangesAsync();
}
}
然而，任务是非静态的，我使用它只是调用SavePoint(point); (不等待)
浏览 4提问于2017-04-24得票数 0
1回答
我有多个api路由，它们分别通过查询数据库返回数据。
现在我正在尝试构建在api之上查询的仪表板。我应该如何将api调用放在队列中，以便异步执行它们？
我试过了
await queue.put({'response_1': await api_1(**kwargs), 'response_2': await api_2(**kwargs)})
当任务被放到队列中时，数据似乎被返回。
现在我在用
await queue.put(('response_1', api_1(**args_dict)))
在生产者和消费者中，我解析元组并进行api调用，我
浏览 5提问于2020-01-19得票数 0
我遇到了一个问题，在这个问题上，我只能从我的主scrapeEbay()函数的内部看到输出数组vars的内容。
这是因为这个函数是异步的吗？我的目的是让主函数能够看到输出数组的内容，并返回它们。但是它们将显示为空，除非在scrapeEbay()函数中记录这些数组。
下面的代码，只是好奇这背后的理由是什么？
var outputPrices = [];
var outputItems = [];
async function scrapeEbay(inputString) {
const browser = await puppeteer.launch({ headless: false }
浏览 2提问于2022-11-16得票数 0
回答已采纳
我的代码运行太快，等待URL验证，而元素没有帮助。这些是我尝试过的等待
wait.Until(ExpectedConditions.ElementToBeClickable(activationCodePage.ConfirmButton()));
wait.Until(e => e.Url.Contains("verify/activation-code"));
我甚至试过
但唯一起作用的似乎是10秒的Thread.sleep()，而我不能/不能将它用于我的测试。
这是代码
verifyEmailPage.ConfirmDepartmentEmailButton(
浏览 1提问于2020-11-18得票数 0
3回答
异步方法等待关键字不挂起调用方法
、、、、
我有以下代码行，以了解async-await和暂停，直到等待任务完成。
public async Task<string> WaitAsynchronouslyAsync()
{
var results = await WaitAsync();
Console.WriteLine($@"I am not waiting");
return results;
}
public async Task<string> WaitAsync()
{
await Tas
浏览 1提问于2017-06-05得票数 0
当(无意中)将异步和syn任务混合时，我遇到了很大的问题:下面的示例是原始问题的压缩版本。
平台是Windows 10，Microsoft.NET.Sdk.Web，2核，4逻辑处理器@ 2.4 GHz
这段代码代表了最初的问题:它执行一个同步任务和一个异步任务，每次执行20次：
var sema = new SemaphoreSlim(1);
var tasks = new List<Task>();
for (int i = 0; i < 20; i++)
{
var t2 = Task.Run(async () =>
{
var
浏览 4提问于2021-03-03得票数 1
回答已采纳
1回答
当我调用test1()方法时，ManagedThreadId将在延迟(1)之后被更改。
当我调用test2()方法(而不是test1())时，ManagedThreadId将保持不变。
什么时候异步等待更改线程？
在test2()方法中，完成方法所需的时间比test1()更长
[Route("api/[controller]")]
[HttpGet]
public async Task<IActionResult> Get()
{
await MainAsync();
return ne
浏览 0提问于2017-04-19得票数 2
回答已采纳
4回答
异步函数是否总是需要等待调用？
、、、、
首先，我有一个异步函数，它记录MongoDB数据库上的消息。
async function log_message(sender, conversationId, text) {
try {
const msg = new Message({
sender: sender,
conversationId: conversationId,
text: text
});
await msg.save();
console.log("Done"
浏览 8提问于2020-01-28得票数 15
回答已采纳
我正在尝试从'anunturi_postate‘引用列表中获取所有数据。推送到列表中的变量'post_data‘在循环中看起来没问题，但在循环之外，列表中它是空的。 我从控制台和firestore模拟器添加了一个图像，以便更好地了解我正在尝试做的事情。 ? // db = firebase.firestore()
async function postedByUser(){
let query = await db.collection("users").doc($current_user.uid).get()
let user_p
浏览 15提问于2020-12-04得票数 0
回答已采纳
我试图在for循环中使用nodejs中的request模块来生成facebook请求。但是我需要进行循环并请求调用同步。我做错了什么？
async function sendRequestAsync(sender, messageData) {
await request({
url: "https://graph.facebook.com/v2.6/me/messages",
qs: {access_token: PAGE_ACCESS_TOKEN},
method: "P
浏览 2提问于2018-06-03得票数 0
回答已采纳
2回答
我开始理解await是如何对具有“底层”硬件任务的一系列async方法进行编程的，比如写入文件(没有线程)。但是，如果数据库是本地的，那么await对数据库调用(如ExecuteQueryAsync )有什么意义呢？从技术上讲，这不是一个CPU绑定的任务，因为SQL server需要一个线程来执行查询？
浏览 0提问于2017-10-26得票数 3
为什么我的阻塞线程在其他线程输出一次之前输出两次？我希望能够派生出在后台(立即)运行的任务，而不是等待它们在主代码继续之前完成。有什么简单的方法可以用tokio做到这一点吗？
代码：
use std::{thread, time};
use chrono;
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
println!("Starting up");
tokio::spawn(blocking_thread()).await.u
浏览 4提问于2022-01-21得票数 1
我能够使用Task.WhenAll(tasks)并行地填充数据库的多个表。我对每个表都有一个泛型方法： var tasks = new List<Task>()
{
CheckNewItems<S, T>(async () => await GetPrimaryKeys<S, T>(),
CheckNewItems<S, T>(async () => await GetPrimaryKeys<S, T>(),
CheckNewItem
浏览 52提问于2020-01-29得票数 0
回答已采纳
在这个瀑布步骤中，
public async processRequest(stepContext: WaterfallStepContext): Promise<DialogTurnResult> { ...
我正在尝试返回或结束对话，如下所示：
return await stepContext.endDialog(JSON.stringify(dataPayload));
但是，我不能返回session.run(查询)结果中的步骤。
有没有办法使用瀑布步骤使response函数返回stepContext？
下面是示例Neo4j驱动程序会话，
session
.run(que
浏览 15提问于2019-10-31得票数 0
我正在学习Dart：
main() async
{
ReceivePort receivePort = ReceivePort();
Isolate.spawn(echo, receivePort.sendPort);
// await for(var msg in receivePort)
// {
// print(msg);
// }
receivePort.listen((msg) { print(msg);} );
}
echo(SendPort sendPort) async
{
ReceivePort receivePort = Rec
浏览 4提问于2019-07-12得票数 0
我有一个数组1,2,3,4,5，当插入到数据库I中时，除了接收结果外，数据库中的结果是1,2,3,4,5。但是只有循环for会给我一个预期的结果，map()和forEach()总是给我一个无序的数组，比如1,3,4,5,2或4,3,2,5,1等等。这是我的代码： arrayChild.map(async item => {
await this.repository.save(item)
});
arrayChild.forEach(async item => {
await this.repository.save(item)
});
for (let i
浏览 91提问于2021-11-01得票数 2
2回答
我有两个异步方法返回值，其中一个是立即需要的，另一个可能正在使用，根据第一个结果。但是，我不想在开始第二个方法并创建一个执行序列依赖之前等待第一个结果。
使用ES7语法，我假设await-ing a Promise将与返回Promise的函数await-ing相同，但它不起作用：
async function tester() {
async function foo() { await setTimeout(() => {}, 2000)}
async function bar() { await setTimeout(() => {}, 1000)}
l
浏览 1提问于2016-01-05得票数 2
回答已采纳
1回答
代码中有5个工人在工作。每个工人都是这样的(短代码)： async def worker(name):
queue_item = await queue.get()
msg = queue_item.message #<--- first attempt
#.....#
try:
#...get_message fails(timeout)...raise#
except errors.TimedOutError:
#Retry to get the message
msg = await
浏览 33提问于2021-01-30得票数 2
回答已采纳
我正在尝试编写一个迭代器，它在等待IO绑定任务的同时进入迭代的下一个步骤。粗略地演示我试图在代码中做什么
for i in iterable:
await io_bound_task() # move on to next step in iteration
# do more stuff when task is complete
我最初尝试使用一个简单的for循环运行，使用一个模拟IO绑定任务的sleep
import asyncio
import random
async def main() -> None:
for i in range(3):
浏览 3提问于2022-03-19得票数 2
回答已采纳
我正在努力理解asyncio.create_task实际上是如何工作的。假设我有以下代码：
import asyncio
import time
async def delayer():
await asyncio.sleep(1)
async def messenger():
await asyncio.sleep(1)
return "A Message"
async def main():
message = await messenger()
await delayer()
start_time = time.time()
浏览 2提问于2022-11-17得票数 0
1回答
我需要发出100个get请求，以便从不同的页面生成100个BeautifulSoup对象。
为了练习我的异步技能，我编写了两个函数，每个函数生成100个get响应，并从同一个页面创建100个BeautifulSoup对象。我还需要使用sleep，因为我正在使用imdb.com，他们不喜欢太多的响应：
异步版
# Gets a BeautifulSoup from a url asynchronously
async def get_page_soup(url):
response_text = await get_response_text(url)
return Beauti
浏览 2提问于2021-08-02得票数 0
1回答
我正在开发一个移动应用程序与React。我查询数据库，并使用"SELECT“请求检索数据。
问题是我无法得到这个请求的结果。我想检索这个请求的结果，将所有元素存储在一个列表变量中。
以下是“选择”请求的代码：
listProduct()
{
return new Promise((resolve) =>
{
const db = SQLite.openDatabase('database.db')
db.transaction(
tx => {
tx.
浏览 4提问于2020-05-24得票数 2
回答已采纳
我有一个async方法：
public async void BillSubscriptions()
{
await Task.Run(() => ProcessSubscriptions(_subscriptionRepository));
await Task.Run(() => ProcessNonRecurringSubscriptions(_subscriptionRepository));
await Task.Run(() => ProcessTrialSubscriptions(_subscriptionRepository));
}
请注意
浏览 0提问于2016-02-09得票数 1
回答已采纳
1回答
我在JavaScript的async/await函数上遇到了问题。这发生在一个内部应用程序上，我不能分享它的源代码，但我把我的问题快速地概括了一下：
function sleep(ms) {
return new Promise(resolve => setTimeout(resolve, ms));
}
async function baz(input) {
console.log("4");
await sleep(1000);
console.log("5");
return input;
}
async function
浏览 0提问于2018-04-18得票数 4
回答已采纳
2回答
我们目前正在对项目的各个部分进行重构，以实现上下异步，耶！
由于我们的理解不同，我和一位同事(让我们称他为Jim)对异步/等待代码将如何执行以及如何编写它有不同的看法。
Jim写的示例方法如下：
public async Task<HouseModel> GetHouseModel(Guid houseId)
{
House house = await _houseService.GetHouse(houseId);
Task<IEnumerable<Furniture>> furniture = _furnitureService.Get
浏览 1提问于2018-08-22得票数 48
回答已采纳
1回答
我只是在youtube上看async/await 。
据我对await的理解，如果await在一个任务中，当执行任务时，当它在任务中遇到await时，它会返回到事件循环。
因此，如果for循环中的await (即10个循环)，任务将暂停10次，我应该在事件循环中使用10 await来完成任务，如下所示：
import asyncio
async def print_numbers():
for i in range(10):
print(i)
await asyncio.sleep(0.25)
async def main():
task2
浏览 2提问于2021-04-24得票数 2
回答已采纳
我有一段代码，我不太确定这是否会异步运行。下面我编写了一些示例脚本，真实地反映了这种情况。请注意，GetAsync方法是适当的asyn方法，具有async/await关键字和使用相关对象的Task的返回类型。
public async Task<SomeResults> MyMethod()
{
var customers = _customerApi.GetAllAsync("some_url");
var orders = _orderApi.GetAllAsync("some_url");
var products =
浏览 1提问于2019-10-30得票数 3
我以前已经成功地测试了一个使用ES7异步/等待语法的角控制器。
async updateGridAsync() {
const paging = angular.copy(this.gridData.getServerCallObj());
}
try {
const model = await this.service.getAsync(paging);
this._$rootScope.$apply();
} catch (e){this._notific
浏览 2提问于2017-08-10得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
