• 17、监测数据采集物联网应用开发步骤(12.2)

    阶段性源码将于本章节末尾给出下载

    1. 监测数据采集物联网应用开发步骤(12.1)

    新建web数据接口http-request解析类com.zxy.tcp.Request.py

    1. #! python3
    2. # -*- coding: utf-8 -
    3. '''
    4. Created on 2017年05月10日
    5. @author: zxyong 13738196011
    6. '''
    7.  
    8. import urllib.parse,json
    9. from com.zxy.common import Com_Para
    10. from com.zxy.common.Com_Fun import Com_Fun
    11. from com.zxy.model.Return_Value import Return_Value               
    12. from com.zxy.z_debug import z_debug
    13.  
    14. #监测数据采集物联网应用--web数据接口http-request解析
    15. class Request(z_debug):
    16.  
    17.     attStrIP = ""
    18.     attServSocket = None
    19.     attUri = ""
    20.     attPost_str = []
    21.     attRv = Return_Value()
    22.     attUploadFile = ""
    23.     attConnection = ""
    24.     
    25.     def __init__(self):
    26.         pass
    27.     
    28.     def parseUri(self,inputValue):
    29.         temStrResult = ""
    30.         if inputValue.find("/favicon.ico") != -1:
    31.             temStrResult += "favicon.ico"
    32.             return temStrResult
    33.         elif inputValue.find(Com_Para.Inf_Name) != -1:
    34.             for temStrITem in inputValue.split("\r\n"):
    35.                 if temStrITem.find(Com_Para.Inf_Name) != -1:
    36.                     if (temStrITem.split(" ")[1]).find("?") != -1:
    37.                         temStrResult += urllib.parse.unquote(temStrITem.split(" ")[1].split("?")[1])
    38.                     else:
    39.                         temStrResult += urllib.parse.unquote(temStrITem.split(" ")[1])
    40.                     break
    41.         elif self.FindWebName(inputValue):
    42.             for temStrITem in inputValue.split("\r\n"):
    43.                 if self.FindWebName(temStrITem):
    44.                     temStrT = temStrITem.split(" ")[1]
    45.                     if temStrT.find("?") == -1:
    46.                         temStrResult = urllib.parse.unquote(temStrITem.split(" ")[1],Com_Para.U_CODE)
    47.                     else:
    48.                         temStrResult = urllib.parse.unquote(temStrT[0:temStrT.find("?")],Com_Para.U_CODE)
    49.                     break
    50.         elif len(inputValue) > 10:
    51.             temStrResult = inputValue
    52.         return temStrResult
    53.     
    54.     def FindWebName(self,inputValue):
    55.         for temAttF in Com_Para.web_Name:
    56.             if inputValue.find(temAttF) != -1:
    57.                 return True
    58.         return False
    59.     
    60.     def PostData(self,inputValue):
    61.         temStrResult = ["",""]
    62.         if self.FindWebName(inputValue):
    63.             temStrTem = inputValue.split("\r\n")
    64.             if len(temStrTem[0].split(" ")) > 1 and (temStrTem[0].split(" ")[0] == "POST" or temStrTem[0].split(" ")[0] == "OPTIONS") :
    65.                 temContent_Length = -1
    66.                 temStrEnd = inputValue[len(inputValue) - 4:len(inputValue)]
    67.                 if temStrEnd != "\r\n\r\n":
    68.                     temStrResult[1] = temStrTem[len(temStrTem) - 1]
    69.                 for temStrItem in temStrTem:
    70.                     temStrItem = urllib.parse.unquote(temStrItem,Com_Para.U_CODE)
    71.                     if temStrItem.find("post_param: ") == 0:
    72.                         temStrResult[1] = temStrItem[temStrItem.find("post_param: ") + 12:len(temStrItem)]
    73.                         temStrResult[0] = "Content-Length:"
    74.                         temStrResult[0] += str(len(temStrResult[1]))
    75.                         break
    76.                     if temStrItem.find("Content-Length:") == 0:
    77.                         temContent_Length = int(temStrItem.split(":")[1].strip())
    78.                         temStrResult[0] = "Content-Length:"
    79.                         temStrResult[0] += str(temContent_Length)
    80.                     if temContent_Length > 0 and temContent_Length == len(temStrResult[1].encode(Com_Para.U_CODE)):
    81.                         break
    82.         return temStrResult
    83.     
    84.     def GetHttpHeadByte(self,inputValue):
    85.         temResult = {}
    86.         for temStrItem in inputValue.split(b"\r\n"):
    87.             if temStrItem.find(b"POST") == 0 or temStrItem.find(b"GET") == 0:                
    88.                 strKey = temStrItem.split(b" ")[0]          
    89.                 strValue = temStrItem.split(b" ")[1]
    90.             else:
    91.                 strKey = temStrItem[0:temStrItem.find(b":")]            
    92.                 strValue = temStrItem[len(strKey)+1:len(temStrItem)]
    93.             if Com_Fun.GetHashTableNone(temResult, strKey) == None:
    94.                 Com_Fun.SetHashTable(temResult, strKey, strValue)
    95.         return temResult
    96.     
    97.     def GetHttpHead(self,inputValue):
    98.         temResult = {}
    99.         for temStrITem in inputValue.split("\r\n"):
    100.             if temStrITem.find("POST") == 0 or temStrITem.find("GET") == 0:                
    101.                 strKey = temStrITem.split(" ")[0]          
    102.                 strValue = temStrITem.split(" ")[1]
    103.             else:
    104.                 strKey = temStrITem[0:temStrITem.find(":")]            
    105.                 strValue = temStrITem[len(strKey)+1:len(temStrITem)]
    106.             if Com_Fun.GetHashTableNone(temResult, strKey) == None:
    107.                 Com_Fun.SetHashTable(temResult, strKey, strValue)
    108.         return temResult
    109.     
    110.     def GetHttpHeadArray(self,inputValue):
    111.         inputValue = inputValue[inputValue.find(b"\r\n\r\n")+4:len(inputValue)]
    112.         temResult = []
    113.         for temStrITem in inputValue.split(b"\n"):
    114.             temResult.append(temStrITem)
    115.         return temResult
    116.     
    117.     #从套接字中读取字符信息
    118.     def parse(self):        
    119.         temInit_msg = b'' # 初始化流
    120.         temFile = None
    121.         temValue = ""
    122.         try:        
    123.             temInit_msg = self.attServSocket.recv(20480) #接受数据  20480
    124.             temStrCheck = []
    125.             #特殊符号处理
    126.             try:
    127.                 temValue = temInit_msg.decode(Com_Para.U_CODE)
    128.                 self.attUri = self.parseUri(temValue)
    129.                 temStrCheck = self.PostData(temValue)
    130.             except Exception as et:
    131.                 if temInit_msg.find(b"\r\n\r\n") == -1:
    132.                     return
    133.                 else:
    134.                     temValue = temInit_msg[0:temInit_msg.find(b"\r\n\r\n")].decode(Com_Para.U_CODE)                    
    135.                     self.attUri = self.parseUri(temValue)
    136.                     temStrCheck = self.PostData(temValue)                    
    137.             inputHtHead = self.GetHttpHeadByte(temInit_msg)
    138.             self.attConnection = Com_Fun.GetHashTable(inputHtHead,b"Connection").decode(Com_Para.U_CODE)            
    139.             #数据接口
    140.             if temStrCheck[0] != "" and int(temStrCheck[0].split(":")[1].strip()) == len(temStrCheck[1].encode(Com_Para.U_CODE)):
    141.                 self.attPost_str = urllib.parse.unquote(temStrCheck[1].replace("+","%20"),Com_Para.U_CODE).split("&")
    142.                 if temStrCheck[1] != "":
    143.                     self.attUri += "&" + urllib.parse.unquote(temStrCheck[1].replace("+","%20"),Com_Para.U_CODE)                
    144.             #附件上传
    145.             elif temStrCheck[0] != "" and int(temStrCheck[0].split(":")[1].strip()) > 0:                
    146.                 if self.attUri.find("param_name=upLoadFile") != -1:
    147.                     bSaveFile = False
    148.                     #附件大小
    149.                     iAllLength = int(temStrCheck[0].split(":")[1].strip())
    150.                     if Com_Fun.GetHashTable(inputHtHead,b"Content-Type").find(b"boundary=") == -1:
    151.                         boundary = Com_Fun.Get_New_GUID().encode(Com_Para.U_CODE)
    152.                     else:
    153.                         boundary = Com_Fun.GetHashTable(inputHtHead,b"Content-Type").split(b";")[1].split(b"=")[1]
    154.                     oldFileName = []
    155.                     newFileName = []
    156.                     temFile_dataAry = []
    157.                     bFlagF = -1
    158.                     while iAllLength > 0:
    159.                         bLastCR = False
    160.                         if Com_Fun.GetHashTableNone(inputHtHead, b"Content-Disposition") != None and len(temFile_dataAry) == 0:
    161.                             temFile_dataAry = self.GetHttpHeadArray(temInit_msg)
    162.                             if temInit_msg[len(temInit_msg)-1:len(temInit_msg)] == b'\n':
    163.                                 bLastCR = True
    164.                         else:
    165.                             temInit_msg = self.attServSocket.recv(iAllLength)
    166.                             temFile_dataAry = temInit_msg.split(b'\n')
    167.                             if temInit_msg[len(temInit_msg)-1:len(temInit_msg)] == b'\n':
    168.                                 bLastCR = True                                
    169.                         iIndex = 0
    170.                         for temItem in temFile_dataAry:
    171.                             #判断是否正确附件码
    172.                             if temItem.find(b"--"+boundary) == 0 and temFile is not None:
    173.                                 bSaveFile = True
    174.                                 temFile.close()
    175.                                 temFile = None
    176.                                 bFlagF = -1
    177.                             #判断是否附件模块
    178.                             if temItem.find(b"Content-Disposition: form-data") == 0:
    179.                                 cdAry = temItem.split(b";")
    180.                                 if len(cdAry) == 3 and cdAry[2].find(b"filename=") == 1:
    181.                                     bFlagF = 0                     
    182.                                 else:
    183.                                     bFlagF = -1                            
    184.                             if bFlagF == 0 and temItem.find(b"Content-Disposition:") == 0:
    185.                                 oldN = temItem.split(b":")[1].split(b";")[2].split(b"=")[1].replace(b"\r",b"").replace(b"\n",b"").replace(b"\"",b"")
    186.                                 if oldN != b"" and oldN.find(b".") != -1:
    187.                                     if Com_Para.attUpFile.find((oldN.split(b".")[1].lower()+b"|").decode(Com_Para.U_CODE)) == -1:
    188.                                         oldFileName.append("不符合上传文件格式，上传失败:"+oldN.decode(Com_Para.U_CODE))
    189.                                         newFileName.append("不符合上传文件格式，上传失败:"+oldN.decode(Com_Para.U_CODE))
    190.                                     else:
    191.                                         oldFileName.append(oldN.decode(Com_Para.U_CODE))                                
    192.                                         if oldN.find(b".") == -1:
    193.                                             newFileName.append(Com_Fun.Get_New_GUID().replace("-", "")+".no")                                
    194.                                         else:
    195.                                             newFileName.append(Com_Fun.Get_New_GUID().replace("-", "")+"."+oldN.decode(Com_Para.U_CODE).split(".")[1])
    196.                                         strF = Com_Para.ApplicationPath+Com_Para.zxyPath+"web"+Com_Para.zxyPath+"file"+Com_Para.zxyPath+newFileName[len(newFileName) - 1]
    197.                                         temFile = open(strF, "wb")
    198.                                         bFlagF = 1
    199.                             elif bFlagF == 1 and temItem == b"\r":
    200.                                 bFlagF = 2
    201.                             elif bFlagF == 2 and temFile is not None and iAllLength > 0:
    202.                                 if temItem != b'' and (b"--"+boundary).find(temItem) == 0:
    203.                                     bSaveFile = True
    204.                                     temFile.close()
    205.                                     temFile = None
    206.                                     bFlagF = -1
    207.                                     #break
    208.                                 else:
    209.                                     temFile.write(temItem)
    210.                                     #加上\n间隔符
    211.                                     if iIndex != len(temFile_dataAry) - 1 or bLastCR == True:
    212.                                         temFile.write(b'\n')
    213.                             iIndex = iIndex + 1  
    214.                             iAllLength = iAllLength - len(temItem+b'\n')                  
    215.                     if temFile is not None:
    216.                         bSaveFile = True
    217.                         temFile.close()
    218.                         temFile = None               
    219.                     if bSaveFile == False:                        
    220.                         self.attRv.s_result = 0
    221.                         self.attRv.err_desc = "文件上传失败,请刷新网络或重新上传"
    222.                         self.attUploadFile = "{\"A01_UpLoadFile\":[{\""+Com_Fun.GetLowUpp("s_result")+"\":\"0\",\""+Com_Fun.GetLowUpp("error_desc")+"\":\"上传失败,请刷新网络或重新上传\"}]}"
    223.                         return
    224.                     jso = {}
    225.                     jsary = []
    226.                     iIndex = 0
    227.                     for temItem in oldFileName:
    228.                         temjso = {}
    229.                         temjso[Com_Fun.GetLowUpp("oldFileName")] = temItem
    230.                         temjso[Com_Fun.GetLowUpp("newFileName")] = newFileName[iIndex]
    231.                         jsary.append(temjso) 
    232.                         
    233.                         iIndex = iIndex + 1    
    234.                     jso["A01_UpLoadFile"] = jsary                        
    235.                     self.attUploadFile = json.dumps(jso,ensure_ascii=False)       
    236.                 else:                
    237.                     temStrCheck[1] = ""                
    238.                     temInit_msg = b''
    239.                     temInit_msg = self.attServSocket.recv(20480)
    240.                     temStrCheck[1] = urllib.parse.unquote(temInit_msg.decode(Com_Para.U_CODE),Com_Para.U_CODE)   
    241.                     self.attPost_str = temStrCheck[1].split("&")
    242.                     if temStrCheck[1] != "":
    243.                         self.attUri += "&" + temStrCheck[1]
    244.         except Exception as e:
    245.             self.attRv.s_result = 0
    246.             self.attRv.err_desc = repr(e)
    247.             self.attUploadFile = "{\"A01_UpLoadFile\":[{\""+Com_Fun.GetLowUpp("s_result")+"\":\"0\",\""+Com_Fun.GetLowUpp("error_desc")+"\":\"上传失败,请刷新网络或重新上传\""+ repr(e)+"}]}"
    248.         finally:
    249.             if temFile is not None:
    250.                 temFile.close()
    251.                 temFile = None
    252.             Pass

    在com.zxy.main.Init_Page.py中添加如下内容

    1. from com.zxy.tcp.ServerThreadHttp import ServerThreadHttp
    2.  
    3.  
    4.         
    5.     @staticmethod
    6.     def Start_Http():        
    7.         # 是否启用http协议接口
    8.         if Com_Para.bThread == True:
    9.             # TCP服务
    10.             temSthttp = ServerThreadHttp("", "", Com_Para.port)
    11.             t1 = threading.Thread(target=temSthttp.run, name="ServerHttpThread")
    12.             t1.start()

    web接口服务运行案例MonitorDataCmd.py主文件中编写：

    添加如下内容:

    1.         #web数据接口服务
    2.         Init_Page.Start_Http()

    程序运行之后在浏览器敲入如下内容访问数据接口：

    http://localhost:9000/CenterData?param_name=A01_AAA111&sub_code=&sub_usercode=

    或

    http://localhost:9000/CenterData?param_name=A01_AAA222&sub_code=&sub_usercode=

    运行结果见图：

    后台数据获取调式见：

    com.zxy.business.Ope_DB_Cent.py 

      def Cal_Data(self, inputSub_code, inputParam_name, inputAryParamValue, inputStrIP,inputSession_id,inputHtParam):
    1. 监测数据采集物联网应用开发步骤(12.3)
  • 相关阅读:
    上周热点回顾（7.3-7.9）
    系统运行缓慢，CPU 100%，以及Full GC次数过多问题的排查思路
    基于SpringBoot的花店销售网站
    【Flask基础】六，拦截器/请求钩子（全局+模块+资源选择性放行）
    Cent OS 使用ip addr or nmcli 分配临时IP地址
    linux安装jdk（正式环境）
    Oracle中LEFT JOIN后AND与WHERE的异同
    LibTorch之网络模型构建
    手记系列之六 ----- 分享个人使用kafka经验
    【云原生之Docker实战】使用Docker部署flatnotes笔记工具
  • 原文地址：https://blog.csdn.net/yong427/article/details/133941079