django批量導(dǎo)入數(shù)據(jù)-創(chuàng)新互聯(lián)

一、需求

我們提供的服務(wù)有：成都網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計(jì)、微信公眾號(hào)開發(fā)、網(wǎng)站優(yōu)化、網(wǎng)站認(rèn)證、雨山ssl等。為近1000家企事業(yè)單位解決了網(wǎng)站和推廣的問題。提供周到的售前咨詢和貼心的售后服務(wù)，是有科學(xué)管理、有技術(shù)的雨山網(wǎng)站制作公司

我在數(shù)據(jù)庫中建了一張表，用來保存ucloud云上的project id 和project name

models.py代碼如下

#coding:utf-8 from django.db import models class Project(models.Model):     name = models.CharField(u'項(xiàng)目名稱',max_length=32,blank=True)     id = models.CharField(u'項(xiàng)目ID',max_length=32,unique=True,primary_key=True,blank=True)     create_date = models.DateTimeField(u'創(chuàng)建時(shí)間', auto_now_add=True)     update_date = models.DateTimeField(u'更新時(shí)間', auto_now=True)     def __unicode__(self):         return self.name

admin.py代碼如下

from django.contrib import admin from ucloud.models import * class ProjectAdmin(admin.ModelAdmin):     list_display = ['name','id'] admin.site.register(Project,ProjectAdmin)

django 批量導(dǎo)入數(shù)據(jù)

二、批量導(dǎo)入腳本

現(xiàn)在，我準(zhǔn)備了一個(gè)腳本，通過UcloudAPI獲取到了線上所有的項(xiàng)目的項(xiàng)目ID和項(xiàng)目名稱

#!/usr/bin/env python #-*-coding:utf8-*- from Ucloud_API.config import * from Ucloud_API.sdk import UcloudApiClient from models import * def get_project_info():     ApiClient = UcloudApiClient(base_url, public_key, private_key)     Parameters = {         "Action": "GetProjectList"     }     response = ApiClient.get("/", Parameters)     ids = [         {'ProjectId': _['ProjectId'], 'ProjectName': _['ProjectName']}         for _ in response['ProjectSet']         ]     return ids##腳本執(zhí)行結(jié)果如下 [{'ProjectId': u'org-81', 'ProjectName': u'\u4e0a\u6d77\u522b\u6837\u7ea2\u4fe1\u606f\u6280\u672f\u6709\u9650\u516c\u53f8'}, {'ProjectId': u'org-ja1wvv', 'ProjectName': u'\u5907\u6848\u4e13\u7528'}, {'ProjectId': u'org-wrg10n', 'ProjectName': u'gitlab'}, {'ProjectId': u'org-pni2a2', 'ProjectName': u'PublicTest'}, {'ProjectId': u'org-kbxrx4', 'ProjectName': u'SPMS'}, {'ProjectId': u'org-aws3dj', 'ProjectName': u'\u5b89\u5168\u6d4b\u8bd5'}, {'ProjectId': u'org-vzfixt', 'ProjectName': u'OTA'}, {'ProjectId': u'org-et55qg', 'ProjectName': u'99\u6570\u636e\u540c\u6b65\u4e2d\u8f6c\uff0c\u672c\u9879\u76ee\u4e0e99\u5185\u7f51\u6253\u901a\uff0c\u4e0d\u5141\u8bb8\u6dfb\u52a0\u4efb\u4f55\u673a\u5668'}, {'ProjectId': u'org-ghan2t', 'ProjectName': u'Ops'}, {'ProjectId': u'org-qf4d2n', 'ProjectName': u'iPms'}]

ProjectId對(duì)象表中的id字段，ProjectName對(duì)應(yīng)表中的name字段。

下面是批量導(dǎo)入數(shù)據(jù)的代碼：

#!/usr/bin/env python #-*-coding:utf8-*- from Ucloud_API.config import * from Ucloud_API.sdk import UcloudApiClient from models import * ##通過API獲取數(shù)據(jù) def get_project_info():     ApiClient = UcloudApiClient(base_url, public_key, private_key)     Parameters = {         "Action": "GetProjectList"     }     response = ApiClient.get("/", Parameters)     ids = [         {'ProjectId': _['ProjectId'], 'ProjectName': _['ProjectName']}         for _ in response['ProjectSet']         ]     return ids ##批量導(dǎo)入數(shù)據(jù) def update_project_info():     info = get_project_info()     pids = []     for _ in info:         projectid = _['ProjectId']         pids.append(projectid)         project = None         try:             project = Project.objects.get(pk=projectid)         except Project.DoesNotExist:             project = Project(pk=projectid)         project.name = _['ProjectName']         project.save()     # 刪除本地有但是ucloud上沒有的項(xiàng)目     projectids = [_['pk'] for _ in Project.objects.all().values('pk')]     diff_ids = list(set(projectids).difference(set(pids)))     Project.objects.filter(pk__in=diff_ids).delete()

這里導(dǎo)入數(shù)據(jù)的思路如下：

try:     project = Project.objects.get(pk=projectid) except Project.DoesNotExist:     project = Project(pk=projectid)

先通過get方法獲取對(duì)象，如果對(duì)象bu'存在，則用下面的方法創(chuàng)建該對(duì)象

project = Project(pk=projectid)

如果對(duì)象存在，通過下面的方法更新ProjectName

project.name = _['ProjectName'] project.save()

另外還有一個(gè)需要注意的地方是，數(shù)據(jù)庫中的數(shù)據(jù)要更新。

例如：線上之前有一個(gè)項(xiàng)目aaa，但是后來被刪除了，那么則需要從數(shù)據(jù)庫中刪除該對(duì)象。

使用以下方法；

projectids = [_['pk'] for _ in Project.objects.all().values('pk')] diff_ids = list(set(projectids).difference(set(pids))) Project.objects.filter(pk__in=diff_ids).delete()

將數(shù)據(jù)庫中的對(duì)象列表轉(zhuǎn)換成集合，將線上獲取到的對(duì)象列表也轉(zhuǎn)換成集合，然后通過

set1.difference(set2)

的方法來獲取在set1中存在，但在set2中不存在的對(duì)象，然后用下面的方法刪除

Project.objects.filter(pk__in=diff_ids).delete()

批量導(dǎo)入數(shù)據(jù)還可以使用下面的方法執(zhí)行

def update_project_info():     info = get_project_info()     pids = [_['ProjectId'] for _ in info]     for i in info:         Project.objects.get_or_create(id=i['ProjectId'],name=i['ProjectName'])     projectids = [_['pk'] for _ in Project.objects.all().values('pk')]     #獲取數(shù)據(jù)庫中存在，但線上不存在的projectid     diff_ids = list(set(projectids).difference(set(pids)))     #刪除數(shù)據(jù)庫中多余的數(shù)據(jù)     Project.objects.filter(pk__in=diff_ids).delete()Project.objects.get_or_create(id=i['ProjectId'],name=i['ProjectName'])

 get_or_create() 有就獲取過來，沒有就創(chuàng)建，用它可以避免重復(fù)，但是速度可以會(huì)慢些，因?yàn)橐葒L試獲取，看看有沒有

三、如何執(zhí)行腳本

我們可以將導(dǎo)入數(shù)據(jù)的方法通過問url的方式，來執(zhí)行

#coding:utf-8 from django.shortcuts import render from django.http import HttpResponse,JsonResponse from sdkucloud import * # Create your views here. def index(request):     return HttpResponse('index') def pull_project(request):     update_project_info()     return HttpResponse('OK!')

編輯$APPName/urls.py

from django.conf.urls import include, url from django.contrib import admin from ucloud.views import * urlpatterns = [     url(r'^$',  index),     url(r'^pull_project/$', pull_project) ]

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

當(dāng)前題目：django批量導(dǎo)入數(shù)據(jù)-創(chuàng)新互聯(lián)
網(wǎng)站路徑：http://bm7419.com/article26/dichjg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供微信公眾號(hào)、服務(wù)器托管、網(wǎng)站收錄、品牌網(wǎng)站制作、虛擬主機(jī)、云服務(wù)器

廣告

聲明：本網(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í)需注明來源： 創(chuàng)新互聯(lián)

成都定制網(wǎng)站網(wǎng)頁設(shè)計(jì)