流安排异步任务或协程,状态函数,异步http流和函数

Date Tags stream

异步入流

  1. 异步函数执行的结果不像同步函数一样可以直接赋值给一个变量,异步编程核心思想在于安排(一般体现在回掉函数)
  2. deva的流支持异步函数的运行,运行结果将进入流,可以很方便的在流上编写处理逻辑(提前安排好流的处理逻辑)
more ...

安排异步任务和服务器接受python对象

Date Tags stream
  • 我们经常在python里遇到async定义的函数,或者tornado中的coroutin,等一些异步函数或者对象,非常难于理解和操作。
  • 我们实现了attend这个函数,可以对这些异步任务很好的进行安排,当异步执行好后,会将结果放入到attend指定的流中。
  • 我们只需要在流上提前定义函数安排处理逻辑就好了。
  • 我们有时候服务器需要远程接受一个python对象进行处理,而不是接受json这种字符串类型的东西,我们这里实现py对象远程接收和使用
more ...

函数运算和颜色打印

Date Tags stream
In [1]:
from deva import *
from rich.console import Console
console = Console()
In [2]:
range<<10>>sum>>log#>>debug
[18:22:26] 45                                                                       bus.py:31
Out[2]:
45
In [3]:
from termcolor import colored,cprint
print(colored('hello', 'red'), colored('world', 'green'))
print(colored("hello red world", 'red'))
hello …
more ...

python嵌入式nosql数据库对比和使用例子

Date Tags stream
  1. 嵌入式的库,可方便直接pip安装,不需要单独外面部署
  2. 基于dill的pickle,可以方便的将python对象存储
  3. 三个嵌入式数据库读写对比,看起来差别并不大,实际上都是本地读写文件,不做索要
  4. NB增加了数据库定长设置和时序数据存储回放,,NB默认是dill的pickle,可以存储函数。这里只展示定长存储和函数存储
more ...

执行特定时长的定时器

Date Tags stream
In [1]:
from deva import *
In [2]:
#启动一个定时器,设置ttl为10秒,定时器的func参数默认是读秒输出,interval是1秒。
s = timer(ttl=10)
#将定时器结果打印log
s>>log
In [4]:
# 刚 …
more ...