ruili/hz-application-ml: 合众算法项目 @ d5f5e5e6b9aa8c6e2a64fe14f753ec0cc8c5613c

import oss2
from itertools import islice
import pandas as pd
columns = ["id","VIN","VehModel","VehState","Time","CellVoltage","PackVoltage",'CellMaxVolNum',"CellMinVolNum",'CellTemp','CellMaxTempNum','CellMinTempNum','PackCrnt','VehRmnRng','VehOdo','FltCode',
'FltLvl','VehSpd','PedalAngle','PackSoc','MotorPwr','EnmTemp','InsulationRss','ChrgSta','GPS_lon','GPS_lat','GPS_alt',
  'PowerAlreadyTime','BMSSta','ACSta','OncCmState','HVILSta','OfcAccumTime','OncAccumTime','BmsOncChgCp','BmsOfcPileOutputVol','BmsOfcPileOutputCur','BmsOfcCc','BmsOfcAllowed',
  'OncOutCurrent','OncOutVoltage','OfcStationMaxOutVolt','OfcStationMinOutVolt','OfcStationMaxOutCrnt','OfcStationMinOutCrnt','BmsOfcgVoltageRequest','BmsOfcType','BmsOfcCurrentRequest',
  'BmsOncChgRequest','BmsRequestOutputCurrent','BmsRequestOutputVoltage','BmsOncCc','BmsS2State','HvUpState','HvDownState','CellMaxVol','CellMinVol','CellMaxTemp','CellMinTemp','Tripmeter',
  'VehAccX','VehAccY','StringAngle','PTCSta','PTCPwr','PosRlySta','NegRlySta','OfcPreRlySta','OfcRlySta','OfcPosChrgerTemp','OfcNegChrgerTemp','OncPosChrgerTemp','OncNegChrgerTemp',
  'InstPwrCmsmtion','AvgPwrCmsmtion','SubPwrCmsmtion','BmsCellVoltDiff','DriveMode','BmsBatTempDiff','BmsClmThermalSts','BmsBatteryTotalCapacity','BmsBatteryAvaiCapacity',
  'BmsOncChgCpConn','CellVoltRecTime','CellVoltTotalCount','CellVoltFrameNo','CellVoltFrameCount','CellTempTotalCount','SN','BatteryModel']
auth = oss2.Auth('LTAI4FyoDnXMjqd78rdRDFHN', 'sdFl6vjM9l2rvWiUTzuFQb2xqjUoY5')
bucket = oss2.Bucket(auth, "https://oss-cn-hangzhou.aliyuncs.com", 'ff-hezhong')
df_data = pd.DataFrame(columns = columns)       
for b in oss2.ObjectIterator(bucket,'alg/LUZAGAAA1MA038075/202202251410/'):
    bucket.get_object_to_file(b.key, 'test.txt')
    df = pd.read_csv('test.txt', names=columns, sep=' ')
    df_data = pd.concat([df_data,df])
df_data = df_data.reset_index(drop=True)

import ssl
from kafka import KafkaProducer, KafkaConsumer
from kafka.errors import kafka_errors
import traceback
import json
import pdb
import os
import pandas as pd
import oss2
from itertools import islice
import pandas as pd
context = ssl.create_default_context()
context = ssl.SSLContext(ssl.PROTOCOL_SSLv23)
## The new python(2.7.8+) may cannot ignore the hostname check,
## you could set to ssl.CERT_NONE to walk around the problem,
## or you can change the client to confluent-python-demo 

# context.verify_mode = ssl.CERT_NONE
context.verify_mode = ssl.CERT_REQUIRED
topic = 'toAlgSn' # toAlg, toAlgSn
# context.check_hostname = True
context.load_verify_locations("ca-cert")
consumer = KafkaConsumer(topic, bootstrap_servers=['alikafka-pre-cn-8ed2kw57901x-1.alikafka.aliyuncs.com:9093',
                                            'alikafka-pre-cn-8ed2kw57901x-2.alikafka.aliyuncs.com:9093',
                                            'alikafka-pre-cn-8ed2kw57901x-3.alikafka.aliyuncs.com:9093'],
                         sasl_mechanism="PLAIN",
                         ssl_context=context,
                         security_protocol='SASL_SSL',
                         api_version = (2,2),
                         sasl_plain_username='alikafka_pre-cn-8ed2kw57901x',
                         sasl_plain_password='hlQsApgUUdUxcWEr1uQoM9BeuF8t8vMF',
                         consumer_timeout_ms= 100000000, # 如果10秒内kafka中没有可供消费的数据，自动退出
                         client_id='consumer-python3',
                         auto_offset_reset='earliest',# 消费kafka中最近的数据，如果设置为earliest则消费最早的数据，不管这些数据是否消费
                         enable_auto_commit=True, # 自动提交消费者的offset
                         auto_commit_interval_ms=3000, ## 自动提交消费者offset的时间间隔,

)

columns = ["id","VIN","VehModel","VehState","Time","CellVoltage","PackVoltage",'CellMaxVolNum',"CellMinVolNum",'CellTemp','CellMaxTempNum','CellMinTempNum','PackCrnt','VehRmnRng','VehOdo','FltCode',
'FltLvl','VehSpd','PedalAngle','PackSoc','MotorPwr','EnmTemp','InsulationRss','ChrgSta','GPS_lon','GPS_lat','GPS_alt',
  'PowerAlreadyTime','BMSSta','ACSta','OncCmState','HVILSta','OfcAccumTime','OncAccumTime','BmsOncChgCp','BmsOfcPileOutputVol','BmsOfcPileOutputCur','BmsOfcCc','BmsOfcAllowed',
  'OncOutCurrent','OncOutVoltage','OfcStationMaxOutVolt','OfcStationMinOutVolt','OfcStationMaxOutCrnt','OfcStationMinOutCrnt','BmsOfcgVoltageRequest','BmsOfcType','BmsOfcCurrentRequest',
  'BmsOncChgRequest','BmsRequestOutputCurrent','BmsRequestOutputVoltage','BmsOncCc','BmsS2State','HvUpState','HvDownState','CellMaxVol','CellMinVol','CellMaxTemp','CellMinTemp','Tripmeter',
  'VehAccX','VehAccY','StringAngle','PTCSta','PTCPwr','PosRlySta','NegRlySta','OfcPreRlySta','OfcRlySta','OfcPosChrgerTemp','OfcNegChrgerTemp','OncPosChrgerTemp','OncNegChrgerTemp',
  'InstPwrCmsmtion','AvgPwrCmsmtion','SubPwrCmsmtion','BmsCellVoltDiff','DriveMode','BmsBatTempDiff','BmsClmThermalSts','BmsBatteryTotalCapacity','BmsBatteryAvaiCapacity',
  'BmsOncChgCpConn','CellVoltRecTime','CellVoltTotalCount','CellVoltFrameNo','CellVoltFrameCount','CellTempTotalCount','SN','BatteryModel']
auth = oss2.Auth('LTAI4FyoDnXMjqd78rdRDFHN', 'sdFl6vjM9l2rvWiUTzuFQb2xqjUoY5')
bucket = oss2.Bucket(auth, "https://oss-cn-hangzhou.aliyuncs.com", 'ff-hezhong')
   

for message in consumer:
      print(message.value)
      # 读取vin数据
      # df_data = pd.DataFrame(columns = columns)    
      # for b in oss2.ObjectIterator(bucket,'alg/'+str(message.value,'utf-8').replace("_","/")):
      #       bucket.get_object_to_file(b.key, 'test.txt')
      #       df = pd.read_csv('test.txt', names=columns, sep=' ')
      #       df_data = pd.concat([df_data,df])
      # df_data = df_data.reset_index(drop=True)
      
      # 读取sn数据
      df_data = pd.DataFrame(columns = columns)    
      for b in oss2.ObjectIterator(bucket,'alg/'+str(message.value,'utf-8').replace("_","/")):
            bucket.get_object_to_file(b.key, 'test.txt')
            df = pd.read_csv('test.txt', names=columns, sep=' ')
            df_data = pd.concat([df_data,df])
      df_data = df_data.reset_index(drop=True)
      print(str(len(df_data)))

b'{"sn":"0CZPE007DN0111B4K0000084","key":"0CZPE007DN0111B4K0000084_202202271605","module_model_code":"J9","pack_series_parallerl":"2P96S","cell_battery_type":"E","cell_dict_shape":"3","pack_model_code":"2101TAB","module_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"122","cell_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"09SPE005FA0111B8L0000059","key":"09SPE005FA0111B8L0000059_202202271605","module_model_code":"MODULE_2.64kWh_177Ah_1P4S","pack_series_parallerl":"1P104S","cell_battery_type":"E","cell_dict_shape":"1","pack_model_code":"2101TW","module_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"174","cell_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"001PB047000001A8D0100014","key":"001PB047000001A8D0100014_202202271605","module_model_code":"CB350","pack_series_parallerl":"1P112S","cell_battery_type":"B","cell_dict_shape":"1","pack_model_code":"2101TS","module_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"87","cell_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"0CZPE007DN0111B990000050","key":"0CZPE007DN0111B990000050_202202271605","module_model_code":"J9","pack_series_parallerl":"2P96S","cell_battery_type":"E","cell_dict_shape":"3","pack_model_code":"2101TAB","module_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"122","cell_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"0CZPE007DN0111B800000064","key":"0CZPE007DN0111B800000064_202202271605","module_model_code":"J9","pack_series_parallerl":"2P96S","cell_battery_type":"E","cell_dict_shape":"3","pack_model_code":"2101TAB","module_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"122","cell_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"001PB047000001AA70100148","key":"001PB047000001AA70100148_202202271605","module_model_code":"CB350","pack_series_parallerl":"1P112S","cell_battery_type":"B","cell_dict_shape":"1","pack_model_code":"2101TS","module_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"87","cell_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"0CZPE007DN0111B8S0000045","key":"0CZPE007DN0111B8S0000045_202202271605","module_model_code":"J9","pack_series_parallerl":"2P96S","cell_battery_type":"E","cell_dict_shape":"3","pack_model_code":"2101TAB","module_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"122","cell_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"09SPE006DA0111A9K0000014","key":"09SPE006DA0111A9K0000014_202202271605","module_model_code":"MEAFG","pack_series_parallerl":"1P96S","cell_battery_type":"E","cell_dict_shape":"1","pack_model_code":"2101TZ","module_manufactory":"\xe6\xb1\x9f\xe8\x8b\x8f\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"110","cell_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"0CZPE007DN0111B8T0000051","key":"0CZPE007DN0111B8T0000051_202202271605","module_model_code":"J9","pack_series_parallerl":"2P96S","cell_battery_type":"E","cell_dict_shape":"3","pack_model_code":"2101TAB","module_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"122","cell_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"0CZPE007DN0111B4K0000084","key":"0CZPE007DN0111B4K0000084_202202271606","module_model_code":"J9","pack_series_parallerl":"2P96S","cell_battery_type":"E","cell_dict_shape":"3","pack_model_code":"2101TAB","module_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"122","cell_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"0CZPE007DN0111B990000050","key":"0CZPE007DN0111B990000050_202202271606","module_model_code":"J9","pack_series_parallerl":"2P96S","cell_battery_type":"E","cell_dict_shape":"3","pack_model_code":"2101TAB","module_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"122","cell_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"0CZPE007DN0111B8S0000045","key":"0CZPE007DN0111B8S0000045_202202271606","module_model_code":"J9","pack_series_parallerl":"2P96S","cell_battery_type":"E","cell_dict_shape":"3","pack_model_code":"2101TAB","module_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"122","cell_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"001PB047000001A8D0100014","key":"001PB047000001A8D0100014_202202271606","module_model_code":"CB350","pack_series_parallerl":"1P112S","cell_battery_type":"B","cell_dict_shape":"1","pack_model_code":"2101TS","module_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"87","cell_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"0CZPE007DN0111B8T0000051","key":"0CZPE007DN0111B8T0000051_202202271606","module_model_code":"J9","pack_series_parallerl":"2P96S","cell_battery_type":"E","cell_dict_shape":"3","pack_model_code":"2101TAB","module_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"122","cell_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"001PB047000001AA70100148","key":"001PB047000001AA70100148_202202271606","module_model_code":"CB350","pack_series_parallerl":"1P112S","cell_battery_type":"B","cell_dict_shape":"1","pack_model_code":"2101TS","module_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"87","cell_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"09SPE006DA0111A9K0000014","key":"09SPE006DA0111A9K0000014_202202271606","module_model_code":"MEAFG","pack_series_parallerl":"1P96S","cell_battery_type":"E","cell_dict_shape":"1","pack_model_code":"2101TZ","module_manufactory":"\xe6\xb1\x9f\xe8\x8b\x8f\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"110","cell_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"0CZPE007DN0111B800000064","key":"0CZPE007DN0111B800000064_202202271606","module_model_code":"J9","pack_series_parallerl":"2P96S","cell_battery_type":"E","cell_dict_shape":"3","pack_model_code":"2101TAB","module_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"122","cell_manufactory":"\xe5\x8d\x8e\xe9\xbc\x8e\xe5\x9b\xbd\xe8\x81\x94\xe5\x8a\xa8\xe5\x8a\x9b\xe7\x94\xb5\xe6\xb1\xa0\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0
b'{"sn":"09SPE005FA0111B8L0000059","key":"09SPE005FA0111B8L0000059_202202271606","module_model_code":"MODULE_2.64kWh_177Ah_1P4S","pack_series_parallerl":"1P104S","cell_battery_type":"E","cell_dict_shape":"1","pack_model_code":"2101TW","module_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8","pack_capacity":"174","cell_manufactory":"\xe5\xae\x81\xe5\xbe\xb7\xe6\x97\xb6\xe4\xbb\xa3\xe6\x96\xb0\xe8\x83\xbd\xe6\xba\x90\xe7\xa7\x91\xe6\x8a\x80\xe8\x82\xa1\xe4\xbb\xbd\xe6\x9c\x89\xe9\x99\x90\xe5\x85\xac\xe5\x8f\xb8"}'
0

str(message.value,'utf-8').replace("_","/")

'LUZAGAAA5MA009680/202202271606'

df_data['Time'] = pd.to_datetime(df['Time'],unit='ms')

df_data

	id	VIN	VehModel	VehState	Time	CellVoltage	PackVoltage	CellMaxVolNum	CellMinVolNum	CellTemp	...	BmsBatteryTotalCapacity	BmsBatteryAvaiCapacity	BmsOncChgCpConn	CellVoltRecTime	CellVoltTotalCount	CellVoltFrameNo	CellVoltFrameCount	CellTempTotalCount	SN	BatteryModel
0	1803242740_LUZAGAAA5MA009680_9223370390905621153	LUZAGAAA5MA009680	EP12	2	2022-02-27 08:05:54.654	4.084,4.084,4.085,4.085,4.087,4.087,4.088,4.08...	392.2	26	84	14,15,14,14,14,14,13,13,12,12,12,12,11,12,11,1...	...	4.294967e+09	4.294967e+09	255	1641150270000	96	1	96	32	0CZPE007DN0111B4K0000084	NaN
1	1803242740_LUZAGAAA5MA009680_9223370390905621122	LUZAGAAA5MA009680	EP12	2	2022-02-27 08:05:54.685	4.061,4.063,4.064,4.064,4.064,4.064,4.065,4.06...	390.0	18	84	19,20,19,20,18,19,18,19,16,17,17,18,16,16,16,1...	...	4.294967e+09	4.294967e+09	255	1641171313000	96	1	96	32	0CZPE007DN0111B4K0000084	NaN
2	1803242740_LUZAGAAA5MA009680_9223370390905621106	LUZAGAAA5MA009680	EP12	2	2022-02-27 08:05:54.701	4.084,4.084,4.085,4.085,4.087,4.087,4.088,4.08...	392.2	26	84	14,15,14,14,14,14,13,13,12,12,12,12,11,12,11,1...	...	4.294967e+09	4.294967e+09	255	1641150270000	96	1	96	32	0CZPE007DN0111B4K0000084	NaN
3	1803242740_LUZAGAAA5MA009680_9223370390905621092	LUZAGAAA5MA009680	EP12	2	2022-02-27 08:05:54.715	4.061,4.063,4.064,4.064,4.064,4.064,4.065,4.06...	390.0	18	84	19,20,19,20,18,19,18,19,16,17,17,18,16,16,16,1...	...	4.294967e+09	4.294967e+09	255	1641171313000	96	1	96	32	0CZPE007DN0111B4K0000084	NaN
4	1803242740_LUZAGAAA5MA009680_9223370390905621081	LUZAGAAA5MA009680	EP12	2	2022-02-27 08:05:54.726	4.057,4.058,4.058,4.060,4.060,4.060,4.061,4.06...	389.5	25	84	19,20,19,20,18,19,18,19,16,17,18,18,16,16,17,1...	...	4.294967e+09	4.294967e+09	255	1641171093000	96	1	96	32	0CZPE007DN0111B4K0000084	NaN
...	...	...	...	...	...	...	...	...	...	...	...	...	...	...	...	...	...	...	...	...	...
1293	1803242740_LUZAGAAA5MA009680_9223370390905615845	LUZAGAAA5MA009680	EP12	2	2022-02-27 08:05:59.962	4.067,4.069,4.069,4.070,4.070,4.070,4.071,4.07...	390.5	25	84	18,18,18,18,17,18,17,18,16,16,16,17,15,16,15,1...	...	4.294967e+09	4.294967e+09	255	1641157910000	96	1	96	32	0CZPE007DN0111B4K0000084	NaN
1294	1803242740_LUZAGAAA5MA009680_9223370390905615844	LUZAGAAA5MA009680	EP12	2	2022-02-27 08:05:59.963	4.068,4.070,4.070,4.071,4.071,4.071,4.071,4.07...	390.5	25	84	18,19,18,18,18,18,17,18,16,17,17,17,16,16,15,1...	...	4.294967e+09	4.294967e+09	255	1641157687000	96	1	96	32	0CZPE007DN0111B4K0000084	NaN
1295	1803242740_LUZAGAAA5MA009680_9223370390905615844	LUZAGAAA5MA009680	EP12	2	2022-02-27 08:05:59.963	4.069,4.070,4.071,4.071,4.071,4.071,4.071,4.07...	390.5	25	84	18,19,18,19,18,18,17,18,16,17,17,17,16,16,16,1...	...	4.294967e+09	4.294967e+09	255	1641157336000	96	1	96	32	0CZPE007DN0111B4K0000084	NaN
1296	1803242740_LUZAGAAA5MA009680_9223370390905615843	LUZAGAAA5MA009680	EP12	2	2022-02-27 08:05:59.964	4.083,4.084,4.085,4.084,4.085,4.085,4.087,4.08...	391.7	26	84	14,14,13,14,13,13,12,12,11,12,11,11,10,11,10,1...	...	4.294967e+09	4.294967e+09	255	1641153388000	96	1	96	32	0CZPE007DN0111B4K0000084	NaN
1297	1803242740_LUZAGAAA5MA009680_9223370390905615843	LUZAGAAA5MA009680	EP12	2	2022-02-27 08:05:59.964	4.083,4.084,4.085,4.085,4.085,4.087,4.088,4.08...	392.0	25	84	14,14,14,14,13,13,12,13,12,12,11,12,11,11,10,1...	...	4.294967e+09	4.294967e+09	255	1641152216000	96	1	96	32	0CZPE007DN0111B4K0000084	NaN

1298 rows × 90 columns

test.ipynb 41 KB History Raw

test.ipynb 41 KB

History Raw