django中嵌套的try-except實例
我就廢話不多說了,大家還是直接看代碼吧!
# 因為此時為yaml模板,而且只抓取node port,所以這樣處理效率快content_dict = parse_yaml(content.replace('{{', '').replace('}}', ''))if ’service’ in content_dict.keys(): # 記錄本次yaml里所有的node_port,并更新到數據庫 now_app_list = [] for service_item in content_dict[’service’]: for port_item in service_item[’port’]: if ’nodePort’ in port_item.keys():node_port = int(port_item[’nodePort’])if 30000 <= node_port <= 32000: # 這里判斷比較復雜,如果端口有,而且app相同,不更新。如果端口有,app不一樣,報沖突。如果端口沒有,可插入。 now_app_list.append(node_port) try: AppPort.objects.get(node_port=node_port, app=app) pass except AppPort.DoesNotExist: try: AppPort.objects.get(node_port=node_port) messages.info(self.request, ’nodeport{}端口沖突!’.format(node_port)) return HttpResponseRedirect(reverse_lazy('app:yaml_edit', kwargs=self.kwargs)) except AppPort.DoesNotExist: name = ’{}-{}’.format(app.name, node_port) AppPort.objects.create(name=name,app=app,node_port=node_port )else: messages.info(self.request, ’nodeport{}端口不在指定范圍內(30000-~32000)!’.format(node_port)) return HttpResponseRedirect(reverse_lazy('app:yaml_edit', kwargs=self.kwargs)) # 取出AppPort里所有此app的node_port,多余的要清除。 all_app_list = AppPort.objects.filter(app=app).values_list(’node_port’, flat=True) if all_app_list: # 取交集,也就是數據庫里多余的端口列表 diff_list = [x for x in all_app_list if x not in now_app_list] if diff_list: AppPort.objects.filter(node_port__in=diff_list).delete()
感覺上面這段代碼,應用的技術點蠻多的,作個記錄。
包括其node port的管理思想,提取技巧。
orm的列表扁平化,列表交集,批量刪除
補充知識:Django 在異常捕獲中進行數據庫保存,保存后將異常再拋出
需求:
當我檢查配額時,如果配額不足,我需要將訂單狀態改為5,然后再將原有異常拋出
一:最初做法
try: self.check_quota_enough(create_form) # 檢查配額except Exception as e: self.object.state = 5 self.object.save() raise e
存在問題:django默認開啟了事務,因此我保存訂單狀態后,再拋異常時沒有任何問題
但當我查詢數據庫訂單狀態時,發現異常拋出之前訂單改變的狀態已經丟失
二:優化,使用裝飾器,手動關閉事務
# 在dispatch方法上增加裝飾器,關閉事務class xxxxxxxx(): @method_decorator(transaction.non_atomic_requests) def dispatch(self, request, *args, **kwargs): return super().dispatch(request, *args, **kwargs) def form_valid(self, form): ... ... try: self.check_quota_enough(create_form) # 檢查配額 except Exception as e: self.object.state = 5 self.object.save() raise e
該方法可以解決上述問題
但該方法對整個視圖有效,如果在視圖其他地方需要用到事務的一致性,則顯然不合理
二:優化,定義事務保存點,在局部控制事務一致性
class xxxxxxxx(): def form_valid(self, form): ... ... sid = transaction.savepoint() # 定義事務保存點 try: self.check_quota_enough(create_form) except QuotaNotEnough as e: self.object.state = 5 self.object.save() transaction.savepoint_commit(sid) return self.render_to_json_response(result=False, messages=str(e))
a.save():此處保存了數據
sid = transaction.savepoint():設置保存點
b.save():此處再次保存了數據
接下來就是邏輯處理:如果滿足xxxxxxxx條件,則手動提交,此時a.save()和b.save()保存的數據都會生效。
如果不滿足xxxxxxxx條件,則執行事務回滾,此時我們定義的保存點之前的a.save()數據不會收到影響,但在保存點之后的b.save()的數據將會回滾。
所以我們可以通過調整保存點的位置,實現我們的需求。
以上這篇django中嵌套的try-except實例就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持好吧啦網。
相關文章: