asyncio oracle 异步,带有asyncio futures和RuntimeError的InvalidStateError与aiohttp时使用期货回调...

我是asyncio和aiohttp新手。我目前得到这个错误,不知道为什么我收到InvalidStateError我asyncio未来RuntimeError为我的会议:带有asyncio futures和RuntimeError的InvalidStateError与aiohttp时使用期货回调

Traceback (most recent call last):

File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/runpy.py", line 184, in _run_module_as_main

"__main__", mod_spec)

File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/runpy.py", line 85, in _run_code

exec(code, run_globals)

File "/Users/bli1/Development/QE/idea/trinity-tracer/tracer/tests/tracer.py", line 100, in

sys.exit(main(sys.argv))

File "/Users/bli1/Development/QE/idea/trinity-tracer/tracer/tests/tracer.py", line 92, in main

poster.post()

File "/Users/bli1/Development/QE/idea/trinity-tracer/tracer/utils/poster.py", line 87, in post

results = event_loop.run_until_complete(self.async_post_events(events))

File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/asyncio/base_events.py", line 387, in run_until_complete

return future.result()

File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/asyncio/futures.py", line 274, in result

raise self._exception

File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/asyncio/tasks.py", line 239, in _step

result = coro.send(None)

File "/Users/bli1/Development/QE/idea/trinity-tracer/tracer/utils/poster.py", line 79, in async_post_events

task.add_done_callback(self.send_oracle, task.result(), session)

File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/asyncio/futures.py", line 268, in result

raise InvalidStateError('Result is not ready.')

asyncio.futures.InvalidStateError: Result is not ready.

Task exception was never retrieved

future: exception=RuntimeError('Session is closed',)>

Traceback (most recent call last):

File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/asyncio/tasks.py", line 239, in _step

result = coro.send(None)

File "/Users/bli1/Development/QE/idea/trinity-tracer/tracer/utils/poster.py", line 64, in async_post_event

async with session.post(self.endpoint, data=event) as resp:

File "/Users/bli1/Development/QE/idea/trinity-tracer/lib/python3.5/site-packages/aiohttp/client.py", line 565, in __aenter__

self._resp = yield from self._coro

File "/Users/bli1/Development/QE/idea/trinity-tracer/lib/python3.5/site-packages/aiohttp/client.py", line 161, in _request

raise RuntimeError('Session is closed')

RuntimeError: Session is closed

我所试图做的是POST到端点,然后使用相同的事件POST编辑发布到另一个端点。这将是跑了作为另一async方法作为callback

这里是我的代码:

async def async_post_event(self, event, session):

async with session.post(self.endpoint, data=event) as resp:

event["tracer"]["post"]["timestamp"] = time.time() * 1000.0

event["tracer"]["post"]["statusCode"] = await resp.status

return event

async def send_oracle(self, event, session):

async with session.post(self.oracle, data=event) as resp:

return event["event"]["event_header"]["event_id"], await resp.status

async def async_post_events(self, events):

tasks = []

conn = aiohttp.TCPConnector(verify_ssl=self.secure)

async with aiohttp.ClientSession(connector=conn) as session:

for event in events:

task = asyncio.ensure_future(self.async_post_event(event, session))

task.add_done_callback(self.send_oracle, task.result(), session)

tasks.append(task)

return await asyncio.gather(*tasks)

def post(self):

event_loop = asyncio.get_event_loop()

try:

events = [self.gen_random_event() for i in range(self.num_post)]

results = event_loop.run_until_complete(self.async_post_events(events))

print(results)

finally:

event_loop.close()

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/527722.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

oracle中存储过程可见权限,Oracle数据库存储过程与权限

在执行存储过程时,我们可能会遇到权限问题 ● 定义者权限存储过程 ● 调用者权限存储过程 在数据库中创建存储过程时,定义者权限是缺省模式 当指定AUTHID CURRENT_USER关键字后,便是调用者权限存储过程 他俩之间最根本的差异在于role能否在存…

oracle无效的十六进制数字,值java.sql.SQLException:ORA-01465:无效的十六进制数

我想这private void jButton2ActionPerformed(java.awt.event.ActionEvent evt) {try {// TODO add your handling code here:captureScreen("img.jpg");} catch (Exception ex) {Logger.getLogger(frontendUI.class.getName()).log(Level.SEVERE, null, ex);}try {C…

oracle实例是否有dbid,Oracle如何获得数据库的DBID

Oracle如何获得数据库的DBID在进行数据库恢复的过程中,很多时候我们需要知道Oracle数据库的DBID,通常有以下几种方法可以获得数据库的DBID.法1:在命令行下C:\Documents and Settings\zhhs>rman target /恢复管理器: 版本9.2.0.7.0 - ProductionCopyright (c) 199…

magento php 所需模块,magento博客 - Magento2 创建基本模块

我们将在Magento 2中创建一个简单的模块,完成后,模块将在自定义前端路由的内容中显示“Hello world!”。先决条件毋庸置疑,您需要最新的Magento 2版本在我们开始Magento 2模块开发之前,有两件事是人们经常忘记的&#…

对象工厂PHP,php – 域对象工厂是什么样的?

通常,您可以使用工厂从特定实现中抽象出来.如果您使用新的< classname>运算符,每次都实例化一个特定的类.如果要在以后将此类与其他实现交换,则必须手动更改每个新语句.工厂模式允许您从特定类中抽象.有效的最小用例可能是这样的&#xff1a;interface UserInterface {pu…

手机安装linux不root权限管理,不root手机也能使用linux环境并安装msf等工具

抵挡不住物理键盘的诱惑在key2首发的时候下手了。黑莓的天性&#xff0c;不能root。之前用nexus习惯用linux deploy搭建的kali环境需要root权限&#xff0c;所以虽然key2敲命令很爽&#xff0c;但是不能使用linux deploy真的很可惜。然后找到了termux这个轻量化的神器。无需roo…

a33 linux内核启动网卡,a33核心板启动问题 - nevermore1981的个人空间 - OSCHINA - 中文开源技术交流社区...

测试发现a33核心板有时无法正常启动&#xff0c;通过串口信息显示判断是uboot 对mmc初始化有时会出现问题&#xff1a;[ 0.770][mmc]: ************Try MMC card 2************[ 0.796][mmc]: mmc 2 2xmode config clk[ 0.806][mmc]: mmc 2 data timeout 80[ …

linux查看机器配置命令,linux 下查看机器配置的几个命令

查看硬盘信息&#xff1a;dmesg |grep hdusernamenode01:~> dmesg|grephdactivating NMI Watchdog ... done.testing NMI watchdog ... OK.SCSI device sda: 286748000 512-byte hdwr sectors(146815 MB)SCSI device sda: 286748000 512-byte hdwr sectors(146815 MB)SCSI d…

linux中group命令详解,linux groupmod命令参数及用法详解

需要更改群组的识别码或名称时&#xff0c;可用groupmod指令来完成这项工作。接下来是小编为大家收集的linux groupmod命令参数及用法详解&#xff0c;希望能帮到大家。linux groupmod命令参数及用法详解groupmod(group modify)功能说明&#xff1a;更改群组识别码或名称。语 …

Linux能适应不同的指令集,(转)linux常用指令集

转自: https://blog.csdn.net/itachi85/article/details/68194801.文件目录操作命令ls显示文件和目录列表-l列出文件的详细信息-a列出当前目录所有文件&#xff0c;包含隐藏文件mkdir创建目录-p父目录不存在情况下先生成父目录cd切换目录touch生成一个空文件echo生成一个带内容…

linux中gedit中定义变量,linux中的gedit

python2.x直接中文字符串用u你好&#xff0c;这样刚刚测试了一下#-*-coding:cp936-*-原因导致错误的改变&#xff0c;是因为改了windows行尾在windows的python自带编辑器run&#xff0c;提示加#-*-coding&#xff1a;cp936-*-&#xff0c;加了之后变成‘xd0’错误的Non-ASCII了…

linux perl 单例模式,Perl脚本学习经验(三)--Perl中ftp的使用

使用use Net::FTP;Demo:my $Server 192.168.1.1;my $User admin;my $Password admin;my $ftp Net::FTP->new($Server,Passive > 0, Debug > 1,Timeout > 10) or die "Could not connect.\n";if (defined $ftp){if ($ftp->login($User, $Password)…

实时屏幕监控 linux面板,分享|LXDE、Xfce 及 MATE 桌面环境下的又一系统监视器应用:Multiload-ng...

Multiload-ng 是一个 GTK2 图形化系统监视器应用&#xff0c;可集成到 Xfce、LXDE 及 MATE 的桌面面板中&#xff0c; 它 fork 自原来的 GNOME Multiload 应用。它也可以运行在一个独立的窗口中。Multiload-ng 的特点有&#xff1a;支持以下资源的图形块&#xff1a; CPU&#…

vmware linux ens32,修改Centos7的网卡ens32 改为eth0

1. 修改网卡配置文件vim /etc/sysconfig/network-scripts/ifcfg-eno16777984修改下面两个配置项NAMEens32DEVICEens32改为NAMEeth0DEVICEeth02.网卡配置文件重命名cd /etc/sysconfig/network-scripts/ifcfg-ens32mv ifcfg-ens32 ifcfg-eth03.修改grub来禁用老的命名规则vim /e…

linux关闭自检测进程,CentOS下自动发邮件检测某进程是否存在

目的&#xff1a;利用shell脚本每小时检测数据库是否在运行&#xff0c;当检测到库宕掉时发邮件告警。1.检查sendmail是否在运行service sendmail status没有在运行则启动或安装。如果是linux 6&#xff0c;则检查postfix是否在运行 service postfix status2.pmon是oracle五大关…

linux awk入门,awk入门应用

awk概述awk是一种编程语言&#xff0c;用于在linux/unix下对文本和数据进行处理。数据可以来自标准输入、一个或多个文件&#xff0c;或其它命令的输出。它支持用户自定义函数和动态正则表达式等先进功能&#xff0c;是linux/unix下的一个强大编程工具。它在命令行中使用&#…

const在c语言中作用,在C语言中const作用全面总结.doc

在C语言中const作用全面总结C中的const关键字的用法非常灵活&#xff0c;而使用const将大大改善程序的健壮性&#xff0c;本人根据各方面查到的资料进行总结如下&#xff0c;期望对朋友们有所帮助。Const 是C中常用的类型修饰符,常类型是指使用类型修饰符const说明的类型&#…

龙贝格数值分析作业c语言,数值分析龙贝格实验报告.doc

数值分析龙贝格实验报告实验三 龙贝格方法【实验类型】 验证性【实验学时】 2学时【实验内容】1.理解龙贝格方法的基本思路2.用龙贝格方法设计算法&#xff0c;编程求解一个数值积分的问题。【实验前的预备知识】1&#xff0e;计算机基础知识2&#xff0e;熟悉编程基本思想3&am…

c语言贪吃蛇黑方框,[求助][贪吃蛇]源程序,请教其中一个问题。

[求助]&#xff3b;贪吃蛇&#xff3d;源程序&#xff0c;请教其中一个问题。源程序如下&#xff1a; 我的问题是&#xff0c;调节游戏速度时&#xff0c;数字为什么越大时&#xff0c;有时候竟然越快&#xff1f;#define N 200#include #include #include #define LEFT 0x4b0…

如何理解android的函数,通过Android源码理解回调函数

概述我们先看一下维基百科对回调函数的定义:在计算机程序设计中&#xff0c;回调函数&#xff0c;或简称回调(Callback 即call then back 被主函数调用运算后会返回主函数)&#xff0c;是指通过函数参数传递到其它代码的&#xff0c;某一块可执行代码的引用。这一设计允许了底层…