Python读取实时数据流示例

  

<强> 1,#编码:utf - 8

        选择=[   (“foo”, 1, 2),   ('酒吧','你好'),   (“foo”, 3、4)   ]      def do_foo (x, y):   print (“foo”, x, y)      def do_bar (s):   打印(酒吧,年代)      在选择标签,* args:   如果标签==癴oo”:   do_foo (* args)      elif标签==熬瓢伞?   do_bar (* args)      行='没人:*:2:2:无特权的用户:/var/空:/usr/bin/假的      uname, *字段、homedir sh=line.split (“:”)   打印(sh)   从集合进口双端队列   def搜索(线、模式、历史=5):   previous_lines=双端队列(maxlen=历史)   李的行:   如果模式在李:   收益率,previous_lines   previous_lines.append(李)         #示例用>   投资组合=[   {“名称”:“IBM”、“股票”:100年,“价格”:91.1},   {“名称”:“apple”,“股票”:50岁的“价格”:543.22},   {“名称”:“facebook”,“股票”:200年,“价格”:21.09},   {“名称”:“hp”、“股票”:35岁的“价格”:31.75},   {“名称”:“yahoo”、“股票”:45岁的“价格”:16.35},   {“名称”:“极致”,“股票”:75年,“价格”:115.65}   ]   便宜=heapq。nsmallest(3组合键=λ:年代[价格])   贵=heapq。nlargest(3组合键=λ:年代[价格])   打印(便宜)   打印(昂贵的)      

<强> 3,读取流数据源

  

如果数据是来自一个连续的数据源,我们需要读取连续数据,接下来

  

我们介绍一个适用于许多真是场景的简单解决方案,然而它并不是通用的。

  

操作步骤:

  

在本节中我们将想你演示如何读取一个实时变化的文件,并把输入打印出来。

        导入的时间   进口操作系统   导入系统      如果len (sys.argv) !=2:   打印(“祝辞祝辞sys.stderr,“请输入需要读取的文件名!””)      文件名=sys.argv [1]      如果不是os.path.isfile(文件名):   打印(',祝辞的在系统。stderr,“请给出需要的文件:\ % s \:不是一个文件“%文件名”)      张开f(文件名,“r”):   文件大?os.stat(文件名)[6]   f.seek(文件大小)   而真正的:   在哪里=f.tell ()   行=f.readline ()   如果不行:   time . sleep (1)   f.seek ()   其他:   print(线)   之前      

以上这篇Python读取实时数据流示例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。

Python读取实时数据流示例