pypkg_template 0.1.0dev

概述

…

用法示例

importpipelineddefdetect_ddos(stream):access=pipelined.utils.limit_counter(10*1000)forloginstream:access[log.ip]+=1yield fromaccess.over(100)defblock_ips(stream):foripinstream:# block the ipyieldipddos_monitor=[detect_ddos,block_ips,]source_logs=pipelined.files.follow('/path/to/server/access.log')foripinpipelined.run(ddos_monitor,source_logs):print(ip,"has been blocked.")

资源

• 来源：https://github.com/hanula/pipelined
• 文档：https://github.com/hanula/pipelined

许可证

见LICENSE。