每次在 django 中调用 api 端点时，我们如何调用一个函数

Question

在我的 Django 服务器中，有一个 rest api 我们通过它在数据库中保存值。如果该名称存在于数据库中，那么我会更新该值，否则将创建一个新值和名称。该函数的代码如下：

def getIgnitionData():
    name_list =[]
    value_list =[]
    cursor = connections['ignition'].cursor()
    cursor.execute('SELECT * FROM MDA_table')
    value = cursor.fetchall()
    cursor.execute('SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS where TABLE_NAME = \'MDA_table\'')
    name = cursor.fetchall()

    for i in name:
        name_list.append(str(i[0]))


    for row in value:
        for j in row:
            value_list.append(str(j))

    cursor.close()
    print name_list
    print value

    #Here we will check to see if the variable exists. If so, update the value. If not,
    #then create a new variable.
    for k in range(0,len(name_list)):
        if (Ignition.objects.filter(name = name_list[k]).exists()):
            Ignition.objects.filter(name=name_list[k]).update(value = value_list[k])
        else:
            Ignition.objects.create(name=name_list[k], value=value_list[k])

view_api.py如下：

class IgnitionViewSet(viewsets.ModelViewSet):
    """
    API endpoint that allows to view variables from the ignition database.
    """
    serializer_class = IgnitionSerializer
    #queryset = ignition.objects.all()
    permission_classes = [HasGroupPermission]
    required_groups = {
        'GET': ['Admin', 'Facility', 'Operator'],
        'PUT': [],
        'POST': [],
    }
    ignition.getIgnitionData() # This is where we are calling the function 
    def get_queryset(self):
        return Ignition.objects.all()

当我第一次从浏览器运行获取请求时，代码运行良好，但是如果我在不重新启动服务器的情况下更新数据库中的值，那么它甚至不会打印 name_list（这意味着它不调用代码）。如果我重新启动服务器并访问端点，那么它会获取更新的值。但这并不实用。

我希望每当我调用 api 端点时，它都会从数据库中获取更新的值，这样我就不必每次都重新启动服务器。提前致谢。

Answer 1

您可以覆盖每次视图使用时调用的 dispatch() 方法：

class IgnitionViewSet(viewsets.ModelViewSet):
    """
    API endpoint that allows to view variables from the ignition database.
    """
    serializer_class = IgnitionSerializer
    #queryset = ignition.objects.all()
    permission_classes = [HasGroupPermission]
    required_groups = {
        'GET': ['Admin', 'Facility', 'Operator'],
        'PUT': [],
        'POST': [],
    }

    def dispatch(self, request, *args, **kwargs):
        ignition.getIgnitionData() # This is where we are calling the function 
        return super(IgnitionViewSet, self).dispatch(request, *args, **kwargs)

    def get_queryset(self):
        return Ignition.objects.all()

每次在 django 中调用 api 端点时，我们如何调用一个函数

How do we call a function each time an api end-point is called in django

django

django-models

django-forms

django-rest-framework

django-rest-auth