2. Tags
  3. stream

流安排异步任务或协程，状态函数，异步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 ...