我从文档中获取了这段代码：
static async Task<string> request(string link)
{
HttpResponseMessage response = await client.GetAsync(link);
response.EnsureSuccessStatusCode();
string responseBody = await response.Content.ReadAsStringAsync();
return responseBody;
}
但是当通过我调用一个方法时string user_ip = await request("https://ident.me");我得到一个错误cs4033，它说该方法不是异步的
有这个代码：
class Program
{
static async Task Main()
{
await DownloadAsync();
}
static async Task DownloadAsync()
{
var options = new ProgressBarOptions
{
ProgressCharacter = '─',
ProgressBarOnBottom = true
};
const int totalTicks = 100;
using (WebClient wc = new WebClient())
{
var pbar = new ProgressBar(totalTicks, "Initial message", options);
wc.DownloadProgressChanged += (s, e) => { pbar.Tick(e.ProgressPercentage,"Download XML Plugin..."); };
await wc.DownloadFileTaskAsync(new Uri("http://dev.osel.pp.ua/Consulo/Plugins/com.intellij.xml_2961.zip"),"/home/ketronix/xml.tar.gz");
};
}
}
Main就个人而言，在我看来，该方法具有类型这一事实Task并不好。如何做到这一点，void同时在调用文件下载方法时，在单独的线程中绘制进度条并与下载进度同步？事实上，你只需要做一些事情而不是Task- void，同时继续工作。
谢谢大家。
我怎样才能只定义一次异步客户端 - 一个与服务器的连接然后使用它，但我不知道如何将此客户端定义为类的全局。我只是猜测在每次使用之前创建一个新连接，但这当然是浪费时间。布德欢迎任何建议。图书馆：https ://pypi.org/project/python-binance/
工作代码：
import asyncio
from binance import AsyncClient
class Binance:
async def get_trades(self):
client = await AsyncClient.create() # define two times(two connections) need only one
aggregate_trades = await client.get_all_tickers()
print(aggregate_trades)
await client.close_connection()
async def exchange_info(self):
client = await AsyncClient.create() # define two times(two connections) need only one
exchange_info = await client.get_exchange_info()
print(exchange_info)
await client.close_connection()
async def main():
b = Binance()
await asyncio.gather(b.get_trades(), b.exchange_info())
if __name__ == "__main__":
asyncio.run(main())
应该是（但不起作用）：
import asyncio
from binance import AsyncClient
class Binance:
def __init__(self):
asyncio.run(self.async_init())
async def async_init(self):
self.client = await AsyncClient.create() # define only one time because use much time
async def get_trades(self):
aggregate_trades = await self.client.get_all_tickers()
print(aggregate_trades)
async def exchange_info(self):
exchange_info = await self.client.get_exchange_info()
print(exchange_info)
async def main():
b = Binance()
await asyncio.gather(b.get_trades(), b.exchange_info())
if __name__ == "__main__":
asyncio.run(main())
# Класс, который я далее импортирую и вызову асинхронный метод этого класса для получения результата
class Async_Meta_Trader():
"Класс для работы с торговым терминалом и данными: Класс Meta_Trader login и password, server\
данные эти берем в последующем из файла конфигурации json"
def __init__(self, login_user: int, password_user: str, server_user: str):
self.login = login_user
self.password = password_user
self.server = server_user
async def account_info(self) -> pd.DataFrame:
"Метод для получения информации об торговом счете из терминала"
if not mt5.initialize(login=self.login, password=self.password, server=self.server):
logger.warning(f"initialize() failed connecting to account_trader MetaTrader5, error code = {mt5.last_error()}")
else:
print('Подключение к торговому счету успешно')
account_info_dict = mt5.account_info()._asdict()
df = pd.DataFrame(account_info_dict.items(), columns=['Key', 'Value']) # конвертация
return df
import aiocron # для выполнения задач по расписанию
import asyncio
from My_Class_functions import Meta_Trader # импортировал класс в ко-м есть асин.метод account_info
Terminal = Meta_Trader(login_user=012313, password_user="test", server_user="test")
temp_df = asyncio.run(Terminal.account_info()) # получаю результат из асинх. метода, ко-й в далее вызовет ошибку в ниже следующей асин.функции
@aiocron.crontab(('*/1 * * * *')) # декоратор для вызов асин. функции каждую минуту
async def get_test(): # ??? здесь вызывает ошибку There is no current event loop in thread 'MainThread' #
print("run")
await asyncio.sleep(2)
asyncio.get_event_loop().run_forever()
** 如何正确使用异步方法 :(
例如，我有一个同步（同步）REST 端点和一个异步（异步）REST 端点（它只在几分钟后保存数据并处理它）。
它可能是这样的：
这里的问题是：由于异步请求较早到达我们，它应该下降还是 sunc 请求不应该通过？
同时从同步和异步工作的策略是什么？
UDP: entity = profile - 有状态（NEW, DONE, PROCESS, ERROR）和它自己的生命周期（即第一个人填写然后另一个人确认一切正确，第三个更新并设置价格，所有这些人通过第三方服务与问卷异步工作），您可以同步取消此问卷。
也就是说，我有