转 股票触发指定价格发送到 企业微信

[Python源码]股票价格监听并推送-代码狗

import aiohttp,asyncio,json,time,re,os,datetimeclass StockListen:def __init__(self):#定义需要监听的股票代码列表self.stock_list = ['1.600050','1.601988','1.601288','1.601939']#定义预期价格列表self.expect_price = [6.6,3.0,2.7,5]#定义数据接口api地址self.api_url = 'https://push2his.eastmoney.com/api/qt/stock/kline/get'#定义推送地址self.wechat_url='你的推送地址'#初始化异步请求对象self.session = aiohttp.ClientSession()#定义本地记录文件路径stock.confself.stock_conf = 'stock.conf'async def get_data(self,stock_code):#定义请求头headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/96.0.4664.110 Safari/537.36','referer':'https://quote.eastmoney.com'}#获取当前时间戳now_time = int(time.time()*1000)#定义请求参数params = {'cb': 'jQuery351010027202936442903_1692684817016','secid': stock_code,'ut': 'fa5fd1943c7b386f172d6893dbfba10b','fields1': 'f1,f2,f3,f4,f5,f6','fields2': 'f51,f52,f53,f54,f55','klt': '101','fqt': '1','end': '20500101','lmt': '1','_': now_time}#发起异步请求async with self.session.get(self.api_url, params=params, headers=headers) as resp:#获取响应内容data = await resp.text()#正则匹配提取jQuery351010027202936442903_1692684817016()中的内容data = re.findall('jQuery351010027202936442903_1692684817016\((.*)\);', data)[0]#将数据转换为json格式data_json = json.loads(data)if data_json['data'] is not None:return data_json['data']else:return None#企业微信异步推送,这里可以换成你自己的async def send_wechat(self,title,content):#准备请求数据curtime = time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))data = "你的数据"headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/96.0.4664.110 Safari/537.36','Content-Type': 'application/json'}#发送请求async with self.session.post(url=self.wechat_url,data=json.dumps(data),headers=headers) as response:#获取响应数据response = await response.text()#返回响应数据return response#遍历股票代码列表async def get_stock_code(self):#遍历股票代码列表self.stock_list并通过索引下标获取对应价格self.expect_pricefor i in range(len(self.stock_list)):time.sleep(5)#获取股票代码stock_code = self.stock_list[i]#获取股票价格expect_price = self.expect_price[i]#通过get_data方法获得股票数据data = await self.get_data(stock_code)if data is None:return {"code":100,"msg":"数据获取失败"}#判断股票价格是否低于预期print(data['klines'][0])#,分割数据klines = data['klines'][0].split(',')if float(klines[2]) < float(expect_price):#判断今日是否已经推送过lastrecord = await self.get_stock_push_time(stock_code)if  lastrecord is None:#通过send_wechat方法发送消息response = await self.send_wechat(data['name']+stock_code,klines[2])await self.record_stock_push_time(stock_code)print(response)else:current_time = datetime.datetime.now().strftime("%Y-%m-%d")if lastrecord != current_time:#通过send_wechat方法发送消息response = await self.send_wechat(data['name']+stock_code,klines[2])await self.record_stock_push_time(stock_code)print(response)else:print("今日已推送")else:#如果高于预期则不发送消息print(stock_code+'价格未达到预期')async def get_stock_push_time(self,stock_code):# 检查文件是否存在if os.path.exists("stock.conf"):with open("stock.conf", "r") as file:lines = file.readlines()for line in lines:if line.startswith(stock_code + ","):return line.split(",")[1].strip()return None#记录推送时间到本地文件stock.confasync def record_stock_push_time(self,stock_code):current_time = datetime.datetime.now().strftime("%Y-%m-%d")record = f"{stock_code},{current_time}"# 检查文件是否存在if os.path.exists("stock.conf"):with open("stock.conf", "r") as file:lines = file.readlines()else:lines = []# 更新股票推送时间found_stock = Falsefor i in range(len(lines)):if lines[i].startswith(stock_code + ","):lines[i] = record + "\n"found_stock = Truebreak# 如果股票代码不存在,则添加新记录if not found_stock:lines.append(record + "\n")# 将记录写入文件with open("stock.conf", "w") as file:file.writelines(lines)#单例测试
if __name__ == '__main__':async def ansyc_test():#获取股票代码stock_code = '1.600050'#实例化对象eastmoney_stock_data =StockListen()#发起异步请求data=await eastmoney_stock_data.get_stock_code()await eastmoney_stock_data.session.close()return dataresult=asyncio.get_event_loop().run_until_complete(ansyc_test())print(result)

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/71972.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

用户促活留存新方式——在APP中嵌入小游戏

随着APP同类产品的不断出现&#xff0c;APP开发者们面临着激烈的竞争&#xff0c;很多APP下载后被新的APP取代&#xff0c;获客成本越来越高。同时开发者还会面临用户粘性差、忠诚度低、用完即走、留存困难&#xff0c;商业化价值被大大缩减。 在APP中植入小游戏来提高用户活跃…

指针的应用与用法

指针的应用场景 从刚才的需求看&#xff0c;指针似乎并不是刚需啊&#xff0c;为什么一定要用指针呢&#xff0c;那么难理解&#xff0c;这是因为有些应用场景非他不可&#xff1a; 1.访问单片机的寄存器&#xff1b; 2.函数调用时内存共享&#xff1b; 3.常用数据结构链表&…

什么是Ubuntu LTS?与常规版本的区别

Ubuntu LTS&#xff08;Long-Term Support&#xff09;是Ubuntu操作系统的一个特殊版本&#xff0c;旨在提供更长时间的支持和稳定性。与常规的Ubuntu版本相比&#xff0c;LTS版本在以下几个方面有所不同&#xff1a; 支持周期更长&#xff1a; 使用Ubuntu LTS版本&#xff0c…

半导体厂务液体泄漏问题的挑战与解决方案

在半导体制造领域&#xff0c;液体泄漏是一项极具挑战性的问题。半导体工厂内有着大量的化学品、工艺液体和废水系统&#xff0c;这些液体在制造过程中扮演着至关重要的角色。然而&#xff0c;液体泄漏可能会导致严重的生产中断、环境污染和安全风险。本文将探讨半导体厂务中的…

【Apollo 自动驾驶】Win11 中 WSL2 安装配置 Apollo 环境

【Apollo 自动驾驶】Win11 中 WSL2 安装配置 Apollo 环境 【1】Win11 WSL2 安装配置 Nvidia Cuda 【1.1】检查计算机硬件的显卡信息 计算机图标右击 -> 管理 -> 设备管理器 -> 显示适配器&#xff1b; 【1.2】检查对应显卡并安装 Nvidia 显卡驱动 下载对应的 Nv…

一点感受

做了两天企业数字化转型的评委&#xff0c;涉及全国最顶级的公司、最顶级的实际落地项目案例&#xff0c;由企业真实的落地团队亲自当面讲解。主要是为了了解了解真实的一线、真实的客户、真实的应用现状和应用水平。 &#xff08;1&#xff09;现状 我评审的涉及底层技术平台&…

Docker进入容器出现:bash: vi: command not found

&#x1f388;1 参考文档 docker基础容器中bash: vi: command not found问题解决 | 你邻座的怪同学-CSDN &#x1f50d;2 问题描述 在使用 Docker 容器时&#xff0c;有时候里边没有安装vim&#xff0c;敲vim命令时提示说&#xff1a;vim: command not found。 这个时候就需要…

pytorch学习——循环神经网络RNN讲解及其实现

参考书籍&#xff1a;8.6. 循环神经网络的简洁实现 — 动手学深度学习 2.0.0 documentation 参考视频&#xff1a;54 循环神经网络 RNN【动手学深度学习v2】_哔哩哔哩_bilibili 一.介绍 循环神经网络RNN&#xff08;Recurrent Neural Network &#xff09;是一类广泛应用于序列…

Xilinx IDDR与ODDR原语的使用

文章目录 ODDR原语1. OPPOSITE_EDGE 模式2. SAME_EDGE 模式 ODDR原语 例化模板&#xff1a; ODDR #(.DDR_CLK_EDGE("OPPOSITE_EDGE"), // "OPPOSITE_EDGE" or "SAME_EDGE" .INIT(1b0), // Initial value of Q: 1b0 or 1b1.SRTYPE("SYNC…

`Executor` 接口

Executor 接口是 Java 并发编程中的一个基础接口,用于表示能够执行任务的对象。它是一个功能非常简单的接口,只定义了一个方法 void execute(Runnable command),用于执行传递给它的 Runnable 任务。 以下是 Executor 接口的简单定义: public interface Executor { void e…

css transition属性

如果想实现一些效果&#xff1a;比如一个div容器宽高拉伸效果&#xff0c;或者一些好看的有过渡的效果可以使用 定义和用法 transition 属性是一个简写属性&#xff0c;用于设置四个过渡属性&#xff1a; transition-property transition-duration transition-timing-func…

学习微信小程序 Westore

最近&#xff0c;接到小程序需求&#xff0c;并且是在以前公司老项目上改造&#xff0c;打开项目&#xff0c;发现却不是我想象中的那样&#xff0c;不是上来就是 Page({})&#xff0c;而是create(store,{})&#xff0c;纳尼&#xff1f;&#xff1f;&#xff1f;这什么玩意&am…

go语言的高级特性

go语言调用C语言 go tool cgo main.go

封闭岛屿数量 -- 二维矩阵的dfs算法

1254. 统计封闭岛屿的数目 这道题和 岛屿数量 – 二维矩阵的dfs算法 类似&#xff0c;区别在于不算边缘部分的岛屿&#xff0c;那其实很简单&#xff0c;把上⼀题中那些靠边的岛屿排除掉&#xff0c;剩下的就是「封闭岛屿」了。 关于岛屿的相似题目&#xff1a; 岛屿数量 –…

Chrome 108版(64-bit 108.0.5359.125)网盘下载

还在用Selenium的朋友们注意了&#xff0c;目前Chrome的最新版是116&#xff0c;而官方的Chromedriver只支持到115版。 可惜Google不提供旧版Chrome的下载方式&#xff0c;需要旧版的很难回去了。如果真的想要旧版的Chrome&#xff0c;只能民间自救。 我在2022年12月备份了C盘…

2023-09-07 monetdb-mvc的实现与并发控制-思考

摘要: monetdb用mvc模块实现了并发控制中对于事务的调度管理, mvc可以看作一次执行的完整的抽象. 并发控制中一个比较需要注意的地方就是调度管理以及锁的使用和管理, 是的, 事务对于资源的使用的串行会使用到锁, 但是申请锁和释放锁却不能由事务本身来进行, 而是调度事务的模…

pyspark 系统找不到指定的路径; \Java\jdk1.8.0_172\bin\java

使用用具PyCharm 2023.2.1 1&#xff1a;pyspark 系统找不到指定的路径&#xff0c; Java not found and JAVA_HOME environment variable is not set. Install Java and set JAVA_HOME to point to the Java installation directory. 解决方法&#xff1a;配置正确环境变量…

VR农学虚拟仿真情景实训教学演示

首先&#xff0c;VR农学虚拟仿真情景实训教学提供了更为真实的实践环境。传统的农学实训往往受制于时间、空间和资源的限制&#xff0c;学生只能通过观察或简单的模拟来学习农业知识和技能。而借助虚拟现实技术&#xff0c;学生可以进入虚拟农场&#xff0c;与各种农作物、工具…

Spring手动构建BeanDefinition的几种方法

Spring手动构建BeanDefinition的几种方法 GenericBeanDefinitionRootBeanDefinitionChildBeanDefinitionBeanDefinitionBuilder GenericBeanDefinition Data public class Student {String name;int age; }public void test() {AnnotationConfigApplicationContext context …

数据库分析工具explain

1.id:查询语句的编号 2.select_type:查询类型&#xff0c;有三种&#xff0c;simple简单查询&#xff0c;primary&#xff0c;subquery等 3.table:查询的表 4.type:查询性能&#xff0c;system > const > eq_ref > ref > range > index > ALL system&…