```python
#!/usr/bin/python3
# coding=gbk
'''
Note:
获取文件的改变
Author:redsun
Data:2019/7/10
'''
import os
import time
import urllib3
def GetFileEndChange(File_Path):
'''
从文件尾部开始检查文件追加的内容
:param File_Path: 路径
:return: 输出尾部增加的内容
'''
if os.path.isfile(File_Path):
with open(File_Path, encoding='gbk') as f:
f.seek(0, 2)
cur = f.tell()
temp = 0
text = ''
HelpInfoHead('Change', File_Path, cur)
var = 1
firstdatacheck = ''
# 改写的代码STATR
while var == 1:
# while True:
f.seek(cur)
ch = f.readlines()
CheckFile() #监控文件检测是否存在
# 如果没有读到数据，跳出循环
if not ch:
# if HelpInfoChangeEnd('Change',temp) == 'no':
HelpInfoChangeEnd('Change', temp)
if 1 == 1:
print('监控中...')
time.sleep(3)
# break
else:
print(123)
else:
for line in ch:
text = line
print(text)
print('查看每次的值'+firstdatacheck)
# firstdatacheck=tuidata(text, firstdatacheck)
# 执行每条的推送判断开始
# 按照规范处理text 26;20200810;0.091011;TA;多头开仓;手数=5;开仓价格=3772.8;Service_str1;20200810;0.091
tt = text.split(';')
if not firstdatacheck is None:
if tt[0] != firstdatacheck:
firstdatacheck = tt[0] # 赋值
# print('执行第二条件')
print('当前的firstdatacheck值' + firstdatacheck)
if tt[1] == tt[8]:
sec = abs(float(tt[2]) - float(tt[9]))
print('执行秒的差值1' + str(sec))
if sec < 0.0015:
print('执行推送1')
pushdata(text)
else:
print('不推送3-时间大于15分钟')
else:
print('不推送2-年月日不同11')
else:
print('不推送1-第一个参数没变')
else:
firstdatacheck = tt[0] # 赋值
if tt[1] == tt[8]:
sec = abs(float(tt[2]) - float(tt[9]))
if sec < 0.0015:
print('执行推送2')
pushdata(text)
else:
print('不推送33-时间大于15分钟')
else:
print('不推送22-年月日不同')
HelpInfoContent(text, temp)
# 执行每条的推送判断开始
temp += 1
cur = f.tell()
# 改写的代码END
else:
print('文件'+File_Path+'不存在')
time.sleep(3)
# GetFileEndChange(docname())
GetFileEndChange('Service.log');
def CheckFile():
if os.path.isfile('Service.log'):
print('文件存在继续健康执行....')
else:
print('文件Service.log不存在')
time.sleep(3)
GetFileEndChange('Service.log');
# 推送消息
def pushdata(text):
print('**********************************************************************')
print(text)
print('**********************************************************************')
http = urllib3.PoolManager()
url = 'http://www.test.com/api/User/push?data='+text
http.request('GET', url)
print('发送成功')
def HelpInfoChangeEnd(FuctionName,times=-1):
'''
提示信息——尾部
:return: no 结束 yes 继续
'''
if times == 0:
raw = 1
elif times == -1 :
raw = 'no'
else:
print('Check {times} times. '.format(times=times))
raw = 'yes'
print('No {FuctionName} in {clock}'.format(FuctionName= FuctionName, clock = GetTime()) )
if raw == 'no' or raw == 'NO':
print('check finish ！')
print('----------------------------------------------------------')
sign = 'no'
else:
sign = 'yes'
return sign
def HelpInfoHead(FuctionName, File_Path, bits = -1):
'''
提示信息——头部
:param FuctionName:函数名
:param file_name: 文件名
:param bits: 当前文件结束地址
:return:
'''
file_name = os.path.basename(File_Path)
print(FuctionName)
print('----------------------------------------------------------')
print('Start Listen The File ({file_name}) Info ...'.format(file_name=file_name))
if bits != -1:
print('The File Ends in {bits} bits . '.format(bits=bits))
print('//')
def HelpInfoContent(text, times = 0):
print('**********************************************************')
if times != 0:
print('Check {times} times. '.format(times=times))
print('Changed at {times} content: \n {text}'.format(
times=GetTime(), text=text))
print('**********************************************************')
def GetTime():
'''
返回当前时间
:return:
'''
return time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time()))
def docname():
return time.strftime("%Y%m%d", time.localtime(time.time()))+'_Backup.log'
#GetFileEndChange(docname())
GetFileEndChange('Service.log');
```
- 支付宝身份验证接口踩坑实录-PHP（基于ThinkPHP5）（第二版更新中）
- 抖音小程序开发之授权登录+支付宝支付+微信支付（ThinkPHP5-第三版修订中）
- TP5小知识点锦集（长期更新）
- PHP 二维码生成+识别
- 高德地图点聚合点击事件以及内容渲染
- ThinkPhP5使用phpexcle 导出数据（复制粘贴就可使用）
- Fastadmin微信小程序授权登录+获取手机号插件
- PHP -AES-128-CBC位加密解密
- PHP-Rsa分段加密解密（ThinkPHP5）
- PHP大转盘抽奖代码片段
- Fastadmin 项目上线关闭调试模式注意事项（记一次require-table.js修改事件）
- ThinkPHP5条件查询FIND_IN_SET正反使用
- ThinkPhP5整合微信小程序订阅消息
- think-queue处理延时任务事件
- ThinkPHP5 生成二维码
- Python3定时监控指定文件内容变换-（增加多行，遍历每行进行逻辑分析处理）
- Python3开发声光报警器监控触发报警
- ThinkPHP5下载文件流到本地
- 百度鹰眼抽轨迹集合稀算法&缩放比例调整显示静态图（ThinkPHP5）
- PHP 导出Excle
- Fastadmin 自定义Tab选项卡（B表的条件查询A表的数据，在A表里面加B表的参数作为选项卡）
- Fastadmin 修改url组件跳转为复制功能
- 微信H5分享好友跟朋友圈-基于Easywechat
- Python3抓取监控日志文件关键词跟内容变化修正版
- ThinkPHP5上传图片压缩处理-（解决IOS拍照上传旋转90度问题）最近更新2021年12月9日11:35:07
- 二维数组根据‘key’分组为新的三维数组
- ThinkPHP5 成功部署Workerman 运行示例
- Fastadmin框架TOKEN的使用
- ThinkPHP5 -微信小程序订阅消息开发-插件（插件基于fastadmin开发）
- ThinkPHP5-文本转义emoji表情
- ThinkPHP5 自定义命令行处理 监听Redis key失效触发回调事件，实现延迟任务 实现自动取消订单，自动完成订单
- Fastadmin插件Shopro商城里面短信插件修改为腾讯云短信插件步骤
- Fastadmin框架自定义搜索操作流程
- ThinkPHP5 处理 微信小程序内容安全审核
- Fastadmin自定义快捷搜索之模糊搜索关联他表
- php根据年月获取指定月份天数及日期数组的方法
- PHP构造函数使用校验token
- 基于ThinkPHP5&Redis腾讯云短信验证码注册登录基础业务逻辑代码整合
- ThinkPHP 解决跨域问题
- 支付宝沙箱环境测试支付（好久没做都忘了，写个博客比较省事）
- ThinkPHP5生成抖音小程序带参数二维码
- ThinkPHP5导入Excle-简单丝滑
- PHP生成带参数的小程序二维码
- ThinkPHP5成功调通IOS苹果支付
- swoole写聊天室，简单粗暴
- 微信小程序内容安全鉴别的时候，不成功因为没有转码
- Fastadmin 后台Excle文件上传（更新新增功能）
- Lnmp 配置thinkphp5 Nginx基础设置，包含http+https配置
- 通过经纬度获取数据库信息自动计算地址距离远近
- 二维数组根据某个字段排序
- PHP二维数组去重，最简单的方法
- TP5微信redis列队群发模板消息Sendmsg
- PHP检测是否关注公众号，亲测可用
- 小程序推广分享带参数二维码生成
- 基于ThinkPHP5微信H5授权登录获取用户信息(改进版)
- php过滤微信昵称中的表情
- Socket.io