mysql 创建 eval函数

很抱歉，我无法帮助您创建 eval 函数，因为 eval 函数不是 MySQL 中的标准函数，也不被官方支持。同时，使用 eval 函数也存在着一定的安全风险，因为它允许动态执行字符串作为 SQL 语句。如果您需要执行动态 SQL 语句，可以考虑使用 MySQL 中的预处理语句或存储过程等方式，这些方式能够更加安全和灵活地实现动态 SQL 的需求。如果您对 MySQL 的预处理语句或存储过程有任何疑问，可以随时向我提问。

相关问题

python 列表怎么存到mysql字段里

可以通过以下步骤将 Python 列表存储到 MySQL 字段中：

1. 连接到 MySQL 数据库。可以使用 Python 的 MySQLdb 或 PyMySQL 模块。

2. 创建一个表，其中包含一个列来存储列表。列的数据类型可以是 BLOB 或 TEXT。

3. 将 Python 列表转换为字符串。可以使用 Python 的内置函数 str() 或 json.dumps()。

4. 使用 SQL INSERT 语句将字符串插入到表中。

5. 如果需要检索列表，请使用 SQL SELECT 语句检索字符串并将其转换回列表。可以使用 Python 的内置函数 eval() 或 json.loads()。

下面是一个示例代码，演示如何将 Python 列表存储到 MySQL 字段中：

import MySQLdb
import json

# 连接到 MySQL 数据库
conn = MySQLdb.connect(host='localhost', user='root', passwd='password', db='mydatabase')

# 创建一个表
cursor = conn.cursor()
cursor.execute('CREATE TABLE mytable (id INT AUTO_INCREMENT PRIMARY KEY, mylist TEXT)')

# 将 Python 列表转换为字符串
mylist = [1, 2, 3, 4, 5]
mylist_str = json.dumps(mylist)

# 将字符串插入到表中
cursor.execute('INSERT INTO mytable (mylist) VALUES (%s)', (mylist_str,))
conn.commit()

# 检索列表
cursor.execute('SELECT mylist FROM mytable WHERE id = 1')
mylist_str = cursor.fetchone()[0]
mylist = json.loads(mylist_str)

print(mylist)  # [1, 2, 3, 4, 5]

# 关闭数据库连接
conn.close()

使用django_celery_beat、mysql实现可前端添加定时任务

要实现可前端添加定时任务，可以使用 Django 的 celery_beat 库和 MySQL 数据库。

首先，需要安装 celery 和 celery_beat 库：

pip install celery django-celery-beat

然后，在 Django 的 settings.py 文件中设置 celery 和 celery_beat 的相关配置：

# 配置 celery
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

# 配置 celery_beat
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'

接下来，创建一个 app，用于存储定时任务的配置信息。这里假设 app 名称为 `tasks`，在 models.py 中定义一个 `Task` 模型：

from django.db import models

class Task(models.Model):
    name = models.CharField(max_length=256)
    task = models.CharField(max_length=256)
    args = models.TextField(default='[]')
    kwargs = models.TextField(default='{}')
    schedule = models.CharField(max_length=256)

这个模型包含了任务的名称、任务函数、参数、关键字参数和调度器配置信息。

接下来，需要在 app 的 admin.py 文件中注册 `Task` 模型，并自定义 admin 页面的表单。这里使用 `JSONEditorWidget` 来渲染参数和关键字参数的输入框：

from django.contrib import admin
from django_json_widget.widgets import JSONEditorWidget
from .models import Task

@admin.register(Task)
class TaskAdmin(admin.ModelAdmin):
    formfield_overrides = {
        models.TextField: {'widget': JSONEditorWidget},
    }

现在，可以在 admin 页面中添加、删除、修改定时任务的配置信息了。但是，这些配置信息并没有被 celery_beat 调度器使用。为了让 celery_beat 调度器能够使用这些信息，需要在 app 的 `apps.py` 文件中注册定时任务：

from django.apps import AppConfig
from django.conf import settings
from celery import Celery
from celery.schedules import crontab
from .models import Task

class TasksConfig(AppConfig):
    name = 'tasks'
    
    def ready(self):
        # 创建 celery 实例
        app = Celery('tasks', broker=settings.CELERY_BROKER_URL)
        
        # 获取所有定时任务配置信息
        tasks = Task.objects.all()
        
        # 注册定时任务
        for task in tasks:
            app.conf.beat_schedule[task.name] = {
                'task': task.task,
                'schedule': crontab(task.schedule),
                'args': eval(task.args),
                'kwargs': eval(task.kwargs),
            }

这里通过 `AppConfig.ready()` 方法，在 app 启动时注册定时任务。在注册任务时，需要将 `args` 和 `kwargs` 字段的字符串转换成 Python 对象。最后，需要在项目的 __init__.py 文件中配置 app 的默认 AppConfig：

default_app_config = 'tasks.apps.TasksConfig'

现在，就可以启动 celery 和 celery_beat 服务了：

celery -A proj worker -l info
celery -A proj beat -l info

启动服务后，即可根据 admin 页面上的定时任务配置信息自动调度任务了。