編寫了信號(hào)函數(shù)后,并沒(méi)有如預(yù)期一般在必要時(shí)候觸發(fā),函數(shù)如下:
創(chuàng)新互聯(lián)制作網(wǎng)站網(wǎng)頁(yè)找三站合一網(wǎng)站制作公司,專注于網(wǎng)頁(yè)設(shè)計(jì),成都網(wǎng)站制作、成都做網(wǎng)站,網(wǎng)站設(shè)計(jì),企業(yè)網(wǎng)站搭建,網(wǎng)站開(kāi)發(fā),建網(wǎng)站業(yè)務(wù),680元做網(wǎng)站,已為上1000+服務(wù),創(chuàng)新互聯(lián)網(wǎng)站建設(shè)將一如既往的為我們的客戶提供最優(yōu)質(zhì)的網(wǎng)站建設(shè)、網(wǎng)絡(luò)營(yíng)銷推廣服務(wù)!
@receiver(signals.post_save, sender=Prometheus)
def monitor_prometheus_update(instance, **kwargs):
# 當(dāng)發(fā)生修改時(shí),更新控制臺(tái)url
web_url = "http://{ip}:{port}/{route}".format(ip=instance.ip, port=instance.port, route=instance.url)
Prometheus.objects.filter(ip=instance.ip).update(web_url=web_url)
print("觸發(fā)", web_url, instance)
理論上應(yīng)該在每次信息修改時(shí)觸發(fā),print出觸發(fā)信息,但是并沒(méi)生效,我是在apps.py中定義ready方法:
from django.apps import AppConfig
class ServicesConfig(AppConfig):
name = 'apps.services'
default_auto_field = 'django.db.models.BigAutoField'
def ready(self):
import apps.services.signals
使用startapp創(chuàng)建一個(gè)新的應(yīng)用到指定目錄時(shí),報(bào)錯(cuò):
CommandError: 'apps' conflicts with the name of an existing Python module and cannot be used as an app directory. Please try another directory.
使用的命令是startapp services .apps
在項(xiàng)目目錄下新建apps目錄,然后在其中新建空目錄services,此時(shí)使用命令startapp services ./apps/services
就可以在指定的目錄下創(chuàng)建新的應(yīng)用了。
編寫了Get請(qǐng)求后,需要支持用戶在請(qǐng)求時(shí)攜帶部分參數(shù),方便查詢
使用rest_framework.request.Request
的query_params能夠方便拿到請(qǐng)求參數(shù):
class PrometheusList(APIView):
def get(self,request: Request):
"""
:param request:
:return:
"""
param=request.query_params
if param and 'group' in param.keys():
# 支持通過(guò)group來(lái)進(jìn)行查詢
queryset = Prometheus.objects.filter(group=param['group'])
else:
queryset = Prometheus.objects.all()
s = PrometheusSerializer(instance=queryset, many=True)
return Response(s.data, status = status.HTTP_200_OK)
隨后創(chuàng)建三條記錄,分組不同,進(jìn)行測(cè)試:
執(zhí)行GET請(qǐng)求如下:
GET /api/v1/services/prometheus?group=default
返回結(jié)果
HTTP 200 OK
Allow: GET, HEAD, OPTIONS
Content-Type: application/json
Vary: Accept
[
{
"ip": "1.1.1.1",
"port": 9090,
"url": "",
"web_url": "http://1.1.1.1:9090/",
"group": "default",
"create_by": "2022-08-23 18:06:19",
"update_by": "2022-08-23 18:06:19"
},
{
"ip": "1.1.1.2",
"port": 9090,
"url": "",
"web_url": "http://1.1.1.2:9090/",
"group": "default",
"create_by": "2022-08-23 18:06:25",
"update_by": "2022-08-23 18:06:25"
}
]
在我的模型類中,web_url字段需要依賴于ip、port以及url字段生成,格式如下:
web_url = "http://{ip}:{port}/{url}"
原先使用信號(hào)機(jī)制實(shí)現(xiàn)這種,當(dāng)任意一個(gè)字段變化時(shí)也會(huì)觸發(fā)web_url變化,但是發(fā)現(xiàn)這樣實(shí)現(xiàn)并不好;
新的實(shí)現(xiàn)方法如下,在模型類中實(shí)現(xiàn)save方法:
class Prometheus(models.Model):
STATUS = (
("UP", "運(yùn)行中"),
("DOWN", "已停止")
)
# Prometheus服務(wù)的模型
ip = models.GenericIPAddressField(protocol="IPV4",help_text="指定了Prometheus服務(wù)所在服務(wù)器IP", verbose_name="服務(wù)IP", blank=False,
primary_key=True)
port = models.IntegerField(help_text="指定了Prometheus服務(wù)的端口號(hào),不正確會(huì)導(dǎo)致服務(wù)狀態(tài)獲取異常", verbose_name="服務(wù)端口",
default=9090)
url = models.CharField(max_length=50, help_text="該值對(duì)應(yīng)了Prometheus的啟動(dòng)參數(shù)web.external-url", verbose_name="訪問(wèn)路由",
blank=True)
web_url = models.URLField(help_text="可以通過(guò)此URL跳轉(zhuǎn)到Prometheus的Web", verbose_name="控制臺(tái)", default="")
group = models.CharField(max_length=50, help_text="用戶定義的Prometheus服務(wù)所屬的組", verbose_name="分組", default="default")
status = models.CharField(max_length=50,choices=STATUS, help_text="Prometheus節(jié)點(diǎn)的狀態(tài),已停止時(shí)無(wú)法進(jìn)行部分操作",verbose_name="狀態(tài)", default="DOWN")
create_by = models.DateTimeField(verbose_name="創(chuàng)建時(shí)間", auto_now_add=True)
update_by = models.DateTimeField(verbose_name="更新時(shí)間", auto_now=True)
def save(self, *args, **kwargs):
"""
重寫save方法,自動(dòng)生成web_url
:param args:
:param kwargs:
:return:
"""
self.web_url = "http://{ip}:{port}/{route}".format(ip=self.ip, port=self.port, route=self.url)
super(Prometheus, self).save(*args, **kwargs)
在通用類視圖中,使用默認(rèn)分頁(yè)類的默認(rèn)的返回結(jié)構(gòu)是這樣的:
字段并不是我要的,所以對(duì)其最新一定的自定義;
自定義分頁(yè)類繼承自PageNumberPagination,然后實(shí)現(xiàn)get_paginated_response方法,原本的改方法返回的是OrderDict類型的結(jié)果,不過(guò)我看python3.6以后的dict也是默認(rèn)有序了,所以我覺(jué)得返回dict是沒(méi)問(wèn)題的:
from rest_framework.pagination import PageNumberPagination
class ServicePageNumberPagination(PageNumberPagination):
page_size_query_param = 'page_size'
page_query_param = "page"
max_page_size = 100
def get_paginated_response(self, data):
return Response(dict([
('total', self.page.paginator.count),
('results', data),
('success', True)
]))
這里如果想要在返回的結(jié)構(gòu)中打印出當(dāng)前的url連接,可以通過(guò)get_html_context()方法實(shí)現(xiàn):
get請(qǐng)求中,添加篩選項(xiàng),這里是期望用group和status作為篩選項(xiàng):
需要使用到django-filter
包,使用pip進(jìn)行安裝:
pip install django-filter
修改settings.py全局配置:
INSTALLED_APPS = [
......
'django_filters',
]
REST_FRAMEWORK = {
......
# 過(guò)濾查詢,全局配置
"DEFAULT_FILTER_BACKENDS": [
"django_filters.rest_framework.DjangoFilterBackend"
]
}
在對(duì)應(yīng)的視圖里添加filter_backends
和filterset_fields
:
from django_filters.rest_framework import DjangoFilterBackend
class ServiceMixinView(ListAPIView, CreateAPIView):
"""
查詢、添加Prometheus服務(wù)的操作,設(shè)計(jì)中暫不準(zhǔn)備支持批量更新
"""
# 使用Mixin實(shí)現(xiàn)
queryset = Prometheus.objects.all()
serializer_class = PrometheusSerializer
# 分頁(yè)類的實(shí)現(xiàn)
pagination_class = ServicePageNumberPagination
# 設(shè)置lookup_field
lookup_field = 'ip'
filter_backends = [DjangoFilterBackend]
filterset_fields = ['group', 'status']
這樣便可以在get時(shí)添加param進(jìn)行篩選了:
本文標(biāo)題:【Django】DRF開(kāi)發(fā)中的一些技巧記錄
本文網(wǎng)址:http://m.kartarina.com/article48/dsogehp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供軟件開(kāi)發(fā)、網(wǎng)站導(dǎo)航、企業(yè)建站、虛擬主機(jī)、靜態(tài)網(wǎng)站、ChatGPT
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)