给我举例若依框架一个定时任务存储json字符串查询数据于一个字段的数据表编码
时间: 2024-05-09 19:18:42 浏览: 174
定时任务实例
以下是一个使用定时任务存储JSON字符串并查询数据的示例:
1. 创建数据表
假设我们要存储一个 JSON 字符串到一个名为 `my_table` 的数据表,该表包含两个字段:`id` 和 `data`。其中,`id` 是一个自增长的整数,`data` 是一个长文本类型的字段,用于存储 JSON 字符串。
```
CREATE TABLE my_table (
id INT PRIMARY KEY AUTO_INCREMENT,
data LONGTEXT
);
```
2. 编写定时任务脚本
我们可以使用 Python 的第三方库 `schedule` 来编写一个定时任务脚本,该脚本每隔一分钟就向 `my_table` 数据表中插入一个随机生成的 JSON 字符串。
```python
import json
import random
import schedule
import time
import mysql.connector
# 连接 MySQL 数据库
db = mysql.connector.connect(
host="localhost",
user="root",
password="password",
database="my_database"
)
# 定义一个任务函数
def insert_data():
# 生成一个随机的 JSON 字符串
data = {
"name": "John Doe",
"age": random.randint(18, 60),
"address": {
"street": "123 Main St",
"city": "Anytown",
"state": "CA",
"zip": "12345"
}
}
json_data = json.dumps(data)
# 插入数据到 my_table 表中
cursor = db.cursor()
sql = "INSERT INTO my_table (data) VALUES (%s)"
val = (json_data,)
cursor.execute(sql, val)
db.commit()
print("Inserted data:", json_data)
# 定义一个每分钟执行一次的任务
schedule.every(1).minutes.do(insert_data)
# 不断运行定时任务
while True:
schedule.run_pending()
time.sleep(1)
```
3. 查询数据
我们可以使用 MySQL 的 `JSON_EXTRACT()` 函数来查询 `my_table` 表中的 JSON 数据。例如,如果我们要查询所有年龄大于 30 岁的人的信息,可以使用以下 SQL 语句:
```
SELECT * FROM my_table WHERE JSON_EXTRACT(data, '$.age') > 30;
```
该语句使用 `JSON_EXTRACT()` 函数从 `data` 字段中提取 `age` 属性,并与 30 进行比较。如果 `age` 大于 30,则返回该行数据。
阅读全文