\n| L3 \u4ea7\u51fa\u4e0e\u8d28\u91cf\u7ed3\u679c<\/td>\n | \u5408\u683c\u6570\u3001\u4e0d\u5408\u683c\u6570\u3001\u4e0d\u826f\u4ee3\u7801\u3001\u505c\u673a\u539f\u56e0\u7801\u3001\u5200\u5177\/\u6a21\u5177\u5bff\u547d<\/td>\n | \u4ef6\u7ea7\u6216\u6279\u6b21\u7ea7<\/td>\n | \u8fd9\u6279\u6d3b\u5e72\u5f97\u600e\u4e48\u6837\u3001\u95ee\u9898\u51fa\u5728\u54ea？<\/td>\n | \u4eba\u5de5\u62a5\u5de5\u3001\u89c6\u89c9\u68c0\u6d4b\u3001\u91cf\u5177<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n \u3010\u914d\u56fe\u4f4d\u7f6e1\u3011\u8bf7\u5728\u6b64\u4e0a\u4f20 \u56fe1_\u6838\u5fc3\u6570\u636e\u4e09\u5c42\u4e0e\u91c7\u96c6\u94fe\u8def.png<\/p>\n \u5173\u952e\u5224\u65ad\u5728\u8fd9\u91cc：\u4e09\u5c42\u90fd\u8981\u91c7，\u4f46\u5b58\u50a8\u7b56\u7565\u5b8c\u5168\u4e0d\u540c\u3002<\/p>\n L1 \u548c L2 \u662f\u65f6\u95f4\u5e8f\u5217，\u5199\u5165\u9891\u7387\u9ad8\u3001\u91cf\u5927，\u5e94\u8be5\u8fdb\u65f6\u5e8f\u6570\u636e\u5e93；L3 \u662f\u4e1a\u52a1\u4e8b\u5b9e，\u5929\u7136\u8981\u8ddf\u5de5\u5355\u3001\u6279\u6b21\u7ed1\u5b9a，\u5e94\u8be5\u8fdb\u4e1a\u52a1\u5e93\u3002\u6211\u89c1\u8fc7\u4e0d\u5c11\u9879\u76ee\u628a\u4e09\u5c42\u6df7\u5728\u4e00\u5f20\u8868\u91cc，\u534a\u5e74\u540e\u6570\u636e\u91cf\u4e0a\u6765，\u4e00\u5f20\u62a5\u8868\u67e5\u4e09\u5206\u949f，\u6700\u540e\u6ca1\u4eba\u613f\u610f\u7528，\u7cfb\u7edf\u5c31\u5e9f\u5728\u90a3\u91cc\u3002<\/p>\n \u56db\u3001\u91c7\u96c6\u67b6\u6784：\u8bbe\u5907\u6570\u636e\u4e3a\u4ec0\u4e48\u53ef\u4ee5\u4e0d\u5fc5\u5148\u8fc7 MES<\/h3>\n\u8fd9\u662f\u672c\u6587\u6700\u60f3\u8bf4\u6e05\u7684\u4e00\u70b9\u3002<\/p>\n MES \u7684\u5b9a\u4f4d\u662f\u5de5\u5355\u7ba1\u7406\u3001\u62a5\u5de5\u3001\u8d28\u91cf\u8ffd\u6eaf\u548c\u8fc7\u7a0b\u7ba1\u63a7，\u5b83\u7684\u6570\u636e\u7c92\u5ea6\u662f\u4ef6\u3001\u6279\u3001\u73ed\u6b21\u3002\u800c\u8bbe\u5907\u70b9\u4f4d\u662f\u79d2\u7ea7\u751a\u81f3\u4e9a\u79d2\u7ea7\u7684\u3002\u628a\u540e\u8005\u76f4\u63a5\u5199\u8fdb\u524d\u8005\u7684\u5e93\u91cc，\u4f1a\u5e26\u6765\u4e09\u4e2a\u5177\u4f53\u95ee\u9898：<\/p>\n \n- \u5199\u5165\u653e\u5927：\u4e00\u53f0\u8bbe\u5907 50 \u4e2a\u70b9\u4f4d\u30011 \u79d2\u4e00\u6b21，\u4e00\u5929\u5c31\u662f 432 \u4e07\u6761\u8bb0\u5f55\u3002\u4e8c\u5341\u53f0\u8bbe\u5907\u4e00\u4e2a\u6708\u5c31\u4e0a\u4ebf，MES \u6570\u636e\u5e93\u625b\u4e0d\u4f4f\u3002<\/li>\n
- \u8868\u7ed3\u6784\u81a8\u80c0：\u4e3a\u585e\u4e0b\u9ad8\u9891\u70b9\u4f4d\u800c\u52a0\u7684\u5bbd\u8868，\u4f1a\u8ba9\u539f\u672c\u6e05\u6670\u7684\u5de5\u5355\u6a21\u578b\u53d8\u5f97\u96be\u4ee5\u7ef4\u62a4\u3002<\/li>\n
- \u62d6\u57ae\u751f\u4ea7\u7cfb\u7edf：MES \u662f\u8f66\u95f4\u6bcf\u5929\u90fd\u8981\u7528\u7684\u7cfb\u7edf，\u4efb\u4f55\u67e5\u8be2\u53d8\u6162\u90fd\u4f1a\u76f4\u63a5\u5f71\u54cd\u6392\u4ea7\u548c\u62a5\u5de5，\u8fd9\u4e2a\u4ee3\u4ef7\u6ca1\u4eba\u613f\u610f\u627f\u62c5\u3002<\/li>\n<\/ul>\n
\u66f4\u5408\u7406\u7684\u5206\u5c42\u662f：<\/p>\n \u8bbe\u5907\u5c42：PLC \/ CNC \/ \u4f20\u611f\u5668 \/ \u4eea\u8868
\n \u2193 （Modbus\u3001OPC UA\u3001\u4e32\u53e3\u3001IO \u91c7\u96c6）
\n\u8fb9\u7f18\u5c42：\u8fb9\u7f18\u7f51\u5173 \u2192 \u70b9\u4f4d\u89c4\u8303\u5316 \u2192 \u672c\u5730\u7f13\u5b58（\u65ad\u7f51\u7eed\u4f20）
\n \u2193 （MQTT \u4e0a\u884c，\u5382\u5185\u7f51\u7edc）
\n\u6570\u636e\u5c42：\u65f6\u5e8f\u6570\u636e\u5e93（\u79d2\u7ea7\u539f\u59cb + \u5206\u949f\u7ea7\u805a\u5408）
\n \u2193 （\u6807\u51c6\u63a5\u53e3 \/ \u805a\u5408\u89c6\u56fe）
\n\u5e94\u7528\u5c42：MES \u53d6\u5de5\u5355\u6240\u9700\u7ed3\u679c\u3001\u770b\u677f\u53d6\u72b6\u6001\u3001AI \u53d6\u7279\u5f81 <\/p>\n \u8fd9\u5957\u5206\u5c42\u7684\u53e6\u4e00\u4e2a\u597d\u5904\u662f\u8fb9\u754c\u6e05\u6670：\u8bbe\u5907\u539f\u59cb\u6570\u636e\u3001\u65f6\u5e8f\u5e93\u5b58\u3001\u6a21\u578b\u63a8\u7406\u90fd\u653e\u5728\u5382\u5185，\u53ea\u6709\u805a\u5408\u540e\u7684\u7ed3\u679c\u6309\u9700\u5916\u9001\u3002\u5bf9\u90a3\u4e9b\u660e\u786e\u8981\u6c42\u6570\u636e\u4e0d\u51fa\u5382\u7684\u4f01\u4e1a\u6765\u8bf4，\u8fd9\u6761\u94fe\u8def\u5929\u7136\u6ee1\u8db3\u8981\u6c42，\u4e0d\u9700\u8981\u4e8b\u540e\u6253\u8865\u4e01\u3002<\/p>\n MES \u4e0e\u65f6\u5e8f\u5e93\u7684\u5bf9\u63a5：\u6309\u9700\u53d6\u805a\u5408\u7ed3\u679c<\/h4>\n\u5206\u5c42\u4e4b\u540e，MES \u4e0d\u518d\u76f4\u8fde\u8bbe\u5907\u70b9\u4f4d，\u800c\u662f\u901a\u8fc7\u805a\u5408\u89c6\u56fe\u6216\u6807\u51c6\u63a5\u53e3\u6309\u5de5\u5355\u3001\u6279\u6b21\u53d6\u6570\u3002\u5178\u578b\u505a\u6cd5\u662f：MES \u4fa7\u53ea\u4fdd\u5b58\u5de5\u5355\u53f7\u3001\u6279\u6b21\u53f7\u3001\u8bbe\u5907\u7f16\u53f7\u548c\u8d77\u6b62\u65f6\u95f4，\u53d6\u6570\u65f6\u628a\u8fd9\u6bb5\u65f6\u95f4\u7a97\u53e3\u548c\u70b9\u4f4d\u524d\u7f00\u4f20\u7ed9\u65f6\u5e8f\u5e93，\u7531\u65f6\u5e8f\u5e93\u8fd4\u56de\u5206\u949f\u7ea7\u805a\u5408\u7ed3\u679c\u3002<\/p>\n \u4e0b\u9762\u662f\u4e00\u4e2a SQL \u805a\u5408\u67e5\u8be2\u793a\u4f8b，\u4ece agg_1m \u8868\u6309\u65f6\u95f4\u6bb5\u548c\u70b9\u4f4d\u524d\u7f00\u53d6\u67d0\u5de5\u5355\u5468\u671f\u7684\u8282\u62cd\u4e0e\u4e3b\u8f74\u8d1f\u8f7d\u5747\u503c：<\/p>\n — \u8f93\u5165：\u5de5\u5355\u5468\u671f\u8d77\u6b62\u65f6\u95f4（\u6beb\u79d2）\u3001\u8bbe\u5907\u70b9\u4f4d\u524d\u7f00
\n— \u8f93\u51fa：\u8be5\u5de5\u5355\u5468\u671f\u5185\u6bcf\u5206\u949f\u7684\u8282\u62cd\u4e0e\u4e3b\u8f74\u8d1f\u8f7d\u5747\u503c
\nSELECT
\n a.ts AS minute_ts,
\n a.point AS point,
\n a.v_avg AS avg_value,
\n a.v_min AS min_value,
\n a.v_max AS max_value,
\n a.v_cnt AS sample_cnt
\nFROM agg_1m a
\nWHERE a.ts >= :work_order_start_ms
\n AND a.ts < :work_order_end_ms
\n AND a.point LIKE :point_prefix || '%'
\n AND (
\n a.point LIKE '%.PROCESS.cycle_time'
\n OR a.point LIKE '%.PROCESS.spindle_load'
\n )
\nORDER BY a.point, a.ts; <\/p>\n \u5982\u679c MES \u9700\u8981\u7684\u662f\u5de5\u5355\u7ea7\u7684\u5355\u4e00\u6570\u503c，\u800c\u4e0d\u662f\u9010\u5206\u949f\u660e\u7ec6，\u53ef\u4ee5\u5728\u5916\u5c42\u518d\u5957\u4e00\u5c42\u805a\u5408：<\/p>\n — \u5de5\u5355\u7ea7\u6c47\u603b：\u8282\u62cd\u5747\u503c\u3001\u4e3b\u8f74\u8d1f\u8f7d\u5747\u503c\u4e0e\u6837\u672c\u6570
\nSELECT
\n SUM(CASE WHEN point LIKE '%.PROCESS.cycle_time' THEN v_avg * v_cnt END)
\n \/ NULLIF(SUM(CASE WHEN point LIKE '%.PROCESS.cycle_time' THEN v_cnt END), 0) AS avg_cycle_time,
\n SUM(CASE WHEN point LIKE '%.PROCESS.spindle_load' THEN v_avg * v_cnt END)
\n \/ NULLIF(SUM(CASE WHEN point LIKE '%.PROCESS.spindle_load' THEN v_cnt END), 0) AS avg_spindle_load,
\n SUM(v_cnt) AS total_samples
\nFROM agg_1m
\nWHERE ts >= :work_order_start_ms
\n AND ts < :work_order_end_ms
\n AND point LIKE :point_prefix || '%'
\n AND (point LIKE '%.PROCESS.cycle_time' OR point LIKE '%.PROCESS.spindle_load'); <\/p>\n \u6ce8\u610f\u8fd9\u91cc\u7528\u7684\u662f v_avg * v_cnt \u52a0\u6743，\u800c\u4e0d\u662f\u76f4\u63a5\u5bf9 v_avg \u6c42\u5e73\u5747\u2014\u2014\u5206\u949f\u7ea7\u805a\u5408\u8868\u7684\u6bcf\u4e00\u884c\u4ee3\u8868\u4e0d\u540c\u6570\u91cf\u7684\u539f\u59cb\u6837\u672c，\u76f4\u63a5\u5e73\u5747\u4f1a\u8ba9\u91c7\u6837\u7a00\u758f\u7684\u5206\u949f\u88ab\u8fc7\u5ea6\u653e\u5927\u3002<\/p>\n \u4e3a\u4ec0\u4e48\u8fd9\u79cd\u300c\u6309\u9700\u53d6\u805a\u5408\u7ed3\u679c\u300d\u6bd4 MES \u76f4\u8fde\u8bbe\u5907\u70b9\u4f4d\u66f4\u5408\u7406，\u53ef\u4ee5\u4ece\u4e09\u4e2a\u89d2\u5ea6\u770b：<\/p>\n \n- \u6570\u636e\u91cf\u5dee\u4e86\u4e24\u4e2a\u6570\u91cf\u7ea7：\u4e00\u53f0\u8bbe\u5907\u4e00\u5929 432 \u4e07\u6761\u539f\u59cb\u70b9\u4f4d，\u805a\u5408\u5230\u5206\u949f\u7ea7\u53ea\u5269 1440 \u6761\u3002MES \u6bcf\u6b21\u53d6\u6570\u53ea\u626b\u805a\u5408\u8868，\u67e5\u8be2\u4ece\u5206\u949f\u7ea7\u964d\u5230\u6beb\u79d2\u7ea7，\u5de5\u5355\u62a5\u5de5\u3001\u6279\u6b21\u8ffd\u6eaf\u8fd9\u4e9b\u9ad8\u9891\u64cd\u4f5c\u4e0d\u4f1a\u88ab\u62d6\u6162\u3002<\/li>\n
- \u804c\u8d23\u8fb9\u754c\u6e05\u6670：\u65f6\u5e8f\u5e93\u8d1f\u8d23\u9ad8\u9891\u5199\u5165\u3001\u964d\u91c7\u6837\u548c\u4fdd\u7559\u7b56\u7565，MES \u8d1f\u8d23\u5de5\u5355\u3001\u6279\u6b21\u548c\u4e1a\u52a1\u8bed\u4e49\u3002MES \u4e0d\u9700\u8981\u7406\u89e3\u70b9\u4f4d\u547d\u540d\u89c4\u5219，\u53ea\u9700\u8981\u77e5\u9053\u300c\u8fd9\u4e2a\u5de5\u5355\u3001\u8fd9\u53f0\u8bbe\u5907\u3001\u8fd9\u6bb5\u65f6\u95f4\u300d；\u70b9\u4f4d\u524d\u7f00\u548c\u805a\u5408\u53e3\u5f84\u7531\u6570\u636e\u5c42\u7edf\u4e00\u7ef4\u62a4，\u6539\u4e00\u6b21\u5168\u5382\u751f\u6548\u3002<\/li>\n
- \u6545\u969c\u9694\u79bb：\u8bbe\u5907\u6296\u52a8\u3001\u7f51\u5173\u65ad\u8fde\u3001\u8865\u53d1\u6d2a\u5cf0\u90fd\u53d1\u751f\u5728\u65f6\u5e8f\u5e93\u8fd9\u4e00\u4fa7，MES \u7684\u5e93\u4e0d\u4f1a\u88ab\u5199\u5165\u653e\u5927\u6ce2\u53ca\u3002\u53cd\u8fc7\u6765，MES \u5347\u7ea7\u6216\u62a5\u8868\u9ad8\u5cf0\u4e5f\u4e0d\u4f1a\u5f71\u54cd\u91c7\u96c6\u94fe\u8def，\u4e24\u8fb9\u5404\u81ea\u6f14\u8fdb\u3002<\/li>\n<\/ul>\n
\u843d\u5730\u65f6\u5efa\u8bae\u628a\u53d6\u6570\u903b\u8f91\u5c01\u88c5\u6210\u4e00\u4e2a\u53ea\u8bfb\u63a5\u53e3（\u6bd4\u5982 GET \/api\/oee\/points?work_order=…&prefix=…），MES \u53ea\u8c03\u63a5\u53e3\u3001\u4e0d\u5199 SQL\u3002\u8fd9\u6837\u805a\u5408\u53e3\u5f84\u8c03\u6574\u3001\u65f6\u5e8f\u5e93\u4ece SQLite \u6362\u6210 TDengine \u6216 InfluxDB \u65f6，MES \u4fa7\u4e00\u884c\u4ee3\u7801\u90fd\u4e0d\u7528\u6539\u3002<\/p>\n \u4e94\u3001\u5de5\u7a0b\u5b9e\u73b0：\u4ece PLC \/ CNC \u5230\u65f6\u5e8f\u5e93\u7684\u4e00\u6761\u6700\u5c0f\u94fe\u8def<\/h3>\n\u4e0b\u9762\u7ed9\u4e00\u6bb5\u53ef\u4ee5\u76f4\u63a5\u8dd1\u8d77\u6765\u7684\u53c2\u8003\u5b9e\u73b0\u3002\u4e3a\u4e86\u8ba9\u793a\u4f8b\u4e0d\u4f9d\u8d56\u7279\u5b9a\u786c\u4ef6，\u91c7\u96c6\u4fa7\u505a\u4e86\u53ef\u66ff\u6362\u7684\u5c01\u88c5：\u6709 OPC UA \u670d\u52a1\u5668\u5c31\u8d70 OPC UA，\u6ca1\u6709\u5c31\u7528\u6a21\u62df\u6570\u636e\u5148\u770b\u901a\u94fe\u8def\u3002<\/p>\n 5.1 \u91c7\u96c6\u4e0e\u4e0a\u884c<\/h4>\n# -*- coding: utf-8 -*-
\n"""
\n\u8bbe\u5907\u6570\u636e\u91c7\u96c6\u6700\u5c0f\u94fe\u8def\u793a\u4f8b：\u91c7\u96c6 \u2192 \u70b9\u4f4d\u89c4\u8303\u5316 \u2192 MQTT \u4e0a\u884c
\n\u4f9d\u8d56：pip install asyncua paho-mqtt
\n\u8bf4\u660e：\u751f\u4ea7\u73af\u5883\u8bf7\u8865\u5168\u5f02\u5e38\u5904\u7406\u3001\u65ad\u7f51\u7eed\u4f20\u4e0e\u9274\u6743\u914d\u7f6e\u3002
\n"""
\nimport asyncio
\nimport json
\nimport time
\nimport random
\nfrom datetime import datetime
\n———- 1. \u70b9\u4f4d\u547d\u540d\u89c4\u8303\u5316 ———-
\n\u547d\u540d\u89c4\u5219：{\u5382\u533a}.{\u4ea7\u7ebf}.{\u8bbe\u5907\u7c7b\u578b}.{\u8bbe\u5907\u7f16\u53f7}.{\u4fe1\u53f7\u7c7b\u522b}.{\u4fe1\u53f7\u540d}
\n\u8fd9\u4e00\u6b65\u5fc5\u987b\u6700\u5148\u505a\u3002\u540c\u4e00\u53f0\u8bbe\u5907\u5728\u4e09\u4e2a\u7cfb\u7edf\u91cc\u4e09\u4e2a\u540d\u5b57，\u662f\u540e\u671f\u6700\u96be\u6536\u62fe\u7684\u5751\u3002
\ndef make_point(workshop, line, dev_type, dev_no, category, signal):
\nreturn f"{workshop}.{line}.{dev_type}.{dev_no}.{category}.{signal}"
\ndef normalize(value, scale=1.0, offset=0.0, precision=2):
\n"""\u91cf\u7a0b\u6362\u7b97 + \u7cbe\u5ea6\u6536\u655b，\u907f\u514d\u6d6e\u70b9\u566a\u58f0\u6c61\u67d3\u65f6\u5e8f\u5e93"""
\nreturn round(value * scale + offset, precision)
\n———- 2. \u91c7\u96c6\u5c01\u88c5 ———-
\nclass MockSource:
\n"""\u6a21\u62df\u6570\u636e\u6e90：\u6ca1\u6709\u771f\u5b9e\u8bbe\u5907\u65f6\u5148\u628a\u94fe\u8def\u8dd1\u901a（\u964d\u7ea7\u65b9\u6848）"""
\ndef init(self, device_no):
\nself.device_no = device_no
\nself._state = "RUN"
\nasync def read(self):
\n # \u771f\u5b9e\u573a\u666f\u66ff\u6362\u4e3a OPC UA \/ Modbus \u8bfb\u53d6
\n if random.random() < 0.03:
\n self._state = random.choice(["RUN", "IDLE", "ALARM"])
\n return {
\n "state": self._state, # \u8bbe\u5907\u72b6\u6001（\u79bb\u6563\u91cf）
\n "spindle_load": normalize(random.uniform(20, 85)), # \u4e3b\u8f74\u8d1f\u8f7d %
\n "spindle_speed": normalize(random.uniform(800, 3000), precision=0), # \u8f6c\u901f rpm
\n "cycle_time": normalize(random.uniform(45, 75)), # \u8282\u62cd \u79d2
\n }
\nclass OpcUaSource:
\n"""
\n\u771f\u5b9e OPC UA \u91c7\u96c6：\u8fde\u63a5\u670d\u52a1\u5668 \u2192 \u6309 NodeId \u6279\u91cf\u8bfb\u53d6 \u2192 \u65ad\u7ebf\u91cd\u8fde + \u8bfb\u53d6\u8d85\u65f6
\n\u5173\u952e\u53c2\u6570\u8bf4\u660e：
\nendpoint : OPC UA \u670d\u52a1\u5668\u5730\u5740，\u5982 opc.tcp:\/\/192.168.1.10:4840
\nnode_map : \u4fe1\u53f7\u540d \u2192 NodeId \u7684\u6620\u5c04，NodeId \u5f62\u5982 "ns=2;s=CNC01.SpindleLoad"
\nread_timeout : \u5355\u6b21\u6279\u91cf\u8bfb\u53d6\u8d85\u65f6（\u79d2），\u8d85\u65f6\u5373\u5224\u5b9a\u672c\u6b21\u91c7\u96c6\u5931\u8d25，\u907f\u514d\u4e3b\u5faa\u73af\u88ab\u5361\u6b7b
\nreconnect_interval : \u65ad\u7ebf\u540e\u91cd\u8fde\u95f4\u9694（\u79d2），\u6307\u6570\u9000\u907f\u7684\u8d77\u59cb\u503c
\nmax_reconnect_interval : \u91cd\u8fde\u95f4\u9694\u4e0a\u9650（\u79d2），\u9632\u6b62\u65e0\u9650\u589e\u957f
\n"""
\ndef init(self, endpoint, node_map, read_timeout=3.0,
\nreconnect_interval=1.0, max_reconnect_interval=30.0):
\nself.endpoint = endpoint
\nself.node_map = node_map
\nself.read_timeout = read_timeout
\nself.reconnect_interval = reconnect_interval
\nself.max_reconnect_interval = max_reconnect_interval
\nself._client = None
\nself._nodes = {} # \u4fe1\u53f7\u540d \u2192 Node \u5bf9\u8c61，\u8fde\u63a5\u6210\u529f\u540e\u4e00\u6b21\u6027\u5efa\u597d
\nself._connected = False
\nasync def connect(self):
\n """\u5efa\u7acb\u8fde\u63a5\u5e76\u7f13\u5b58 Node \u5bf9\u8c61；\u5931\u8d25\u65f6\u629b\u51fa\u5f02\u5e38\u7531\u4e0a\u5c42\u91cd\u8fde\u903b\u8f91\u5904\u7406"""
\n from asyncua import Client
\n self._client = Client(url=self.endpoint, timeout=self.read_timeout)
\n await self._client.connect()
\n # \u6279\u91cf\u9884\u53d6 Node \u5bf9\u8c61，\u907f\u514d\u6bcf\u6b21\u8bfb\u53d6\u90fd\u91cd\u65b0\u89e3\u6790 NodeId
\n self._nodes = {
\n signal: self._client.get_node(node_id)
\n for signal, node_id in self.node_map.items()
\n }
\n self._connected = True
\n print(f"[opcua] \u5df2\u8fde\u63a5 {self.endpoint}，\u70b9\u4f4d {len(self._nodes)} \u4e2a")<\/p>\n async def read(self):
\n """\u6309 NodeId \u6279\u91cf\u8bfb\u53d6；\u65ad\u7ebf\u6216\u8d85\u65f6\u8fd4\u56de None，\u7531\u4e3b\u5faa\u73af\u51b3\u5b9a\u662f\u5426\u964d\u7ea7"""
\n if not self._connected:
\n return None
\n try:
\n # read_values \u4e00\u6b21\u8bf7\u6c42\u8bfb\u591a\u4e2a\u8282\u70b9，\u6bd4\u9010\u4e2a read_value \u5c11\u4e00\u4e2a\u6570\u91cf\u7ea7\u7684\u5f80\u8fd4
\n values = await asyncio.wait_for(
\n self._nodes_read(), timeout=self.read_timeout
\n )
\n return values
\n except asyncio.TimeoutError:
\n print(f"[opcua] \u8bfb\u53d6\u8d85\u65f6（>{self.read_timeout}s），\u672c\u6b21\u91c7\u96c6\u8df3\u8fc7")
\n return None
\n except Exception as e:
\n print(f"[opcua] \u8bfb\u53d6\u5f02\u5e38：{e}，\u6807\u8bb0\u65ad\u7ebf")
\n self._connected = False
\n return None<\/p>\n async def _nodes_read(self):
\n """\u5185\u90e8：\u6309 node_map \u987a\u5e8f\u6279\u91cf\u8bfb\u53d6\u5e76\u7ec4\u88c5\u4e3a {\u4fe1\u53f7\u540d: \u503c}"""
\n signals = list(self._nodes.keys())
\n nodes = [self._nodes[s] for s in signals]
\n raw_values = await self._client.read_values(nodes)
\n result = {}
\n for signal, value in zip(signals, raw_values):
\n # \u79bb\u6563\u91cf（state）\u4fdd\u6301\u5b57\u7b26\u4e32\u8bed\u4e49，\u6a21\u62df\u91cf\u4e0e MockSource \u5bf9\u9f50
\n if signal == "state":
\n result[signal] = "RUN" if value else "IDLE"
\n else:
\n result[signal] = normalize(float(value))
\n return result<\/p>\n async def ensure_connected(self):
\n """\u65ad\u7ebf\u91cd\u8fde：\u6307\u6570\u9000\u907f，\u76f4\u5230\u8fde\u4e0a\u6216\u8fbe\u5230\u4e0a\u9650"""
\n delay = self.reconnect_interval
\n while not self._connected:
\n try:
\n await self.connect()
\n return True
\n except Exception as e:
\n print(f"[opcua] \u91cd\u8fde\u5931\u8d25：{e}，{delay:.1f}s \u540e\u91cd\u8bd5")
\n await asyncio.sleep(delay)
\n delay = min(delay * 2, self.max_reconnect_interval)
\n return True<\/p>\n async def close(self):
\n if self._client:
\n try:
\n await self._client.disconnect()
\n except Exception:
\n pass
\n self._connected = False
\n———- 3. MQTT \u4e0a\u884c ———-
\nclass MqttUploader:
\ndef init(self, host, port=1883, topic="factory\/l1\/telemetry"):
\nimport paho.mqtt.client as mqtt
\nself.topic = topic
\nself.client = mqtt.Client(client_id=f"gw-{int(time.time())}")
\nself.client.connect(host, port, keepalive=60)
\nself.client.loop_start()
\ndef publish(self, payload: dict):
\n # qos=1 \u4fdd\u8bc1\u81f3\u5c11\u4e00\u6b21\u9001\u8fbe；\u65f6\u5e8f\u6570\u636e\u5141\u8bb8\u5c11\u91cf\u91cd\u590d，\u4e0d\u5141\u8bb8\u4e22
\n self.client.publish(self.topic, json.dumps(payload), qos=1)
\n———- 4. \u4e3b\u5faa\u73af ———-
\nasync def main():
\nworkshop, line = "SH01", "LINE_A"
\ndevices = [("CNC", "01"), ("CNC", "02")]
\n# \u6709 OPC UA \u670d\u52a1\u5668\u5c31\u8d70\u771f\u5b9e\u91c7\u96c6，\u6ca1\u6709\u5219\u964d\u7ea7\u4e3a MockSource
\nUSE_OPCUA = True
\nOPCUA_ENDPOINT = "opc.tcp:\/\/192.168.1.10:4840"
\nNODE_MAP = {
\n "state": "ns=2;s=CNC01.Status.State",
\n "spindle_load": "ns=2;s=CNC01.Process.SpindleLoad",
\n "spindle_speed": "ns=2;s=CNC01.Process.SpindleSpeed",
\n "cycle_time": "ns=2;s=CNC01.Process.CycleTime",
\n}<\/p>\n sources = {}
\nfor dev_type, dev_no in devices:
\n if USE_OPCUA:
\n src = OpcUaSource(OPCUA_ENDPOINT, NODE_MAP)
\n await src.ensure_connected()
\n sources[dev_no] = src
\n else:
\n sources[dev_no] = MockSource(dev_no)<\/p>\n # \u751f\u4ea7\u73af\u5883\u66ff\u6362\u4e3a\u771f\u5b9e broker \u5730\u5740
\nup = MqttUploader(host="127.0.0.1")<\/p>\n while True:
\n ts = datetime.utcnow().isoformat(timespec="milliseconds") + "Z"
\n batch = []
\n for dev_type, dev_no in devices:
\n src = sources[dev_no]
\n raw = await src.read()
\n # \u8bfb\u53d6\u5931\u8d25：OPC UA \u65ad\u7ebf\u65f6\u964d\u7ea7\u5230 MockSource，\u4fdd\u8bc1\u94fe\u8def\u4e0d\u65ad\u6d41
\n if raw is None:
\n if isinstance(src, OpcUaSource):
\n print(f"[{dev_no}] OPC UA \u4e0d\u53ef\u7528，\u964d\u7ea7\u4e3a\u6a21\u62df\u6570\u636e")
\n raw = await MockSource(dev_no).read()
\n asyncio.create_task(src.ensure_connected()) # \u540e\u53f0\u91cd\u8fde
\n else:
\n continue
\n for signal, value in raw.items():
\n category = "STATUS" if signal == "state" else "PROCESS"
\n batch.append({
\n "ts": ts,
\n "point": make_point(workshop, line, dev_type, dev_no, category, signal),
\n "value": value,
\n })
\n # \u6279\u91cf\u4e0a\u62a5，\u907f\u514d\u9010\u70b9\u53d1\u9001\u628a broker \u6253\u6ee1
\n up.publish({"ts": ts, "data": batch})
\n print(f"[{ts}] \u4e0a\u62a5 {len(batch)} \u4e2a\u70b9\u4f4d")
\n await asyncio.sleep(1)
\nif name == "main":
\nasyncio.run(main()) <\/p>\n \u65ad\u7f51\u7eed\u4f20\u4e0e\u5f02\u5e38\u5904\u7406<\/h5>\n\u4e0a\u9762\u90a3\u6bb5\u4ee3\u7801\u6709\u4e00\u4e2a\u81f4\u547d\u5047\u8bbe：\u7f51\u7edc\u4e00\u76f4\u662f\u901a\u7684\u3002\u8f66\u95f4\u91cc\u65ad\u7f51\u662f\u5e38\u6001\u2014\u2014\u4ea4\u6362\u673a\u91cd\u542f\u3001\u65e0\u7ebf AP \u6389\u7ebf\u3001broker \u5347\u7ea7，\u4efb\u4f55\u4e00\u6b21\u6296\u52a8\u90fd\u4f1a\u8ba9 publish \u629b\u5f02\u5e38\u6216\u8005\u9759\u9ed8\u4e22\u5305\u3002\u6240\u4ee5\u8fb9\u7f18\u7f51\u5173\u5fc5\u987b\u81ea\u5e26\u4e00\u5757\u672c\u5730\u7f13\u5b58，\u65ad\u8fde\u65f6\u5199\u672c\u5730\u3001\u91cd\u8fde\u540e\u6309\u65f6\u95f4\u987a\u5e8f\u8865\u53d1\u3002<\/p>\n \u8fd9\u91cc\u7528 SQLite \u505a\u73af\u5f62\u7f13\u5b58\u961f\u5217，\u96f6\u5916\u90e8\u4f9d\u8d56，\u6389\u7535\u4e5f\u4e0d\u4e22\u3002\u4e09\u4e2a\u8bbe\u8ba1\u8981\u70b9：<\/p>\n \n- \u73af\u5f62\u961f\u5217：\u8868\u91cc\u53ea\u4fdd\u7559\u6700\u8fd1 N \u6761（\u6bd4\u5982 50 \u4e07\u6761），\u8d85\u51fa\u540e\u6309 ts \u6dd8\u6c70\u6700\u8001\u7684，\u9632\u6b62\u78c1\u76d8\u88ab\u5199\u6ee1\u628a\u7f51\u5173\u641e\u5d29\u3002<\/li>\n
- \u6309\u65f6\u95f4\u987a\u5e8f\u8865\u53d1：\u8865\u53d1\u65f6\u4e25\u683c\u6309 ts \u5347\u5e8f\u53d6，\u4fdd\u8bc1\u65f6\u5e8f\u5e93\u91cc\u7684\u6570\u636e\u4e0d\u4e71\u5e8f，\u5426\u5219\u964d\u91c7\u6837\u548c\u8d8b\u52bf\u67e5\u8be2\u90fd\u4f1a\u51fa\u95ee\u9898\u3002<\/li>\n
- \u5e42\u7b49\u53bb\u91cd：qos=1 \u662f\u201c\u81f3\u5c11\u4e00\u6b21\u201d，\u91cd\u8fde\u8865\u53d1\u3001broker \u91cd\u6295\u90fd\u4f1a\u4ea7\u751f\u91cd\u590d\u3002\u843d\u5e93\u4fa7\u7528 (ts, point) \u505a\u8054\u5408\u4e3b\u952e，INSERT OR REPLACE \u5e42\u7b49\u5199\u5165，\u91cd\u590d\u6570\u636e\u81ea\u7136\u88ab\u8986\u76d6\u3002<\/li>\n<\/ul>\n
# -*- coding: utf-8 -*-
\n"""
\n\u65ad\u7f51\u7eed\u4f20：SQLite \u73af\u5f62\u7f13\u5b58\u961f\u5217 + \u91cd\u8fde\u8865\u53d1
\n\u4f9d\u8d56：pip install paho-mqtt
\n\u601d\u8def：\u53d1\u9001\u524d\u5148\u843d\u672c\u5730，\u53d1\u9001\u6210\u529f\u518d\u5220\u9664；\u65ad\u8fde\u65f6\u53ea\u5199\u4e0d\u5220，\u91cd\u8fde\u540e\u6309 ts \u5347\u5e8f\u8865\u53d1\u3002
\n"""
\nimport json
\nimport sqlite3
\nimport time
\nimport threading
\nCACHE_DB = "edge_cache.db"
\nMAX_ROWS = 500_000 # \u73af\u5f62\u961f\u5217\u5bb9\u91cf，\u6309\u78c1\u76d8\u548c\u65ad\u7f51\u65f6\u957f\u4f30\u7b97
\nBATCH_SIZE = 500 # \u5355\u6b21\u8865\u53d1\u6279\u91cf，\u907f\u514d\u4e00\u6b21\u6027\u628a broker \u6253\u6ee1
\nclass LocalQueue:
\n"""\u672c\u5730\u73af\u5f62\u7f13\u5b58\u961f\u5217：\u5148\u843d\u76d8，\u518d\u53d1\u9001，\u6210\u529f\u624d\u5220\u9664"""
\ndef __init__(self, db_path=CACHE_DB, max_rows=MAX_ROWS):
\n self.max_rows = max_rows
\n self._lock = threading.Lock()
\n self.conn = sqlite3.connect(db_path, check_same_thread=False)
\n self.conn.execute("PRAGMA journal_mode=WAL") # \u8bfb\u5199\u5e76\u53d1\u66f4\u7a33，\u6389\u7535\u66f4\u5b89\u5168
\n self.conn.execute("""
\n CREATE TABLE IF NOT EXISTS outbox (
\n id INTEGER PRIMARY KEY AUTOINCREMENT,
\n ts TEXT NOT NULL, — ISO8601 \u6beb\u79d2\u65f6\u95f4\u6233，\u8865\u53d1\u6392\u5e8f\u4f9d\u636e
\n topic TEXT NOT NULL,
\n payload TEXT NOT NULL
\n )
\n """)
\n self.conn.execute("CREATE INDEX IF NOT EXISTS idx_outbox_ts ON outbox(ts)")
\n self.conn.commit()
\ndef put(self, ts, topic, payload):
\n"""\u5165\u961f：\u5199\u5165\u672c\u5730，\u540c\u65f6\u505a\u73af\u5f62\u6dd8\u6c70"""
\nwith self._lock:
\nself.conn.execute(
\n"INSERT INTO outbox (ts, topic, payload) VALUES (?, ?, ?)",
\n(ts, topic, json.dumps(payload, ensure_ascii=False)),
\n)
\n# \u73af\u5f62\u6dd8\u6c70：\u53ea\u4fdd\u7559\u6700\u8fd1 max_rows \u6761
\nself.conn.execute(
\n"DELETE FROM outbox WHERE id <= (SELECT MAX(id) – ? FROM outbox)",
\n(self.max_rows,),
\n)
\nself.conn.commit()
\ndef peek_batch(self, limit=BATCH_SIZE):
\n"""\u6309\u65f6\u95f4\u987a\u5e8f\u53d6\u4e00\u6279\u5f85\u8865\u53d1\u6570\u636e"""
\nwith self._lock:
\ncur = self.conn.execute(
\n"SELECT id, ts, topic, payload FROM outbox ORDER BY ts ASC, id ASC LIMIT ?",
\n(limit,),
\n)
\nreturn cur.fetchall()
\ndef ack(self, ids):
\n"""\u53d1\u9001\u6210\u529f\u540e\u5220\u9664，ack \u4e4b\u524d\u5d29\u6e83\u4f1a\u91cd\u53d1，\u9760\u4e0b\u6e38\u5e42\u7b49\u515c\u5e95"""
\nif not ids:
\nreturn
\nwith self._lock:
\nself.conn.executemany("DELETE FROM outbox WHERE id = ?", [(i,) for i in ids])
\nself.conn.commit()
\ndef pending(self):
\nwith self._lock:
\nreturn self.conn.execute("SELECT COUNT(*) FROM outbox").fetchone()[0]
\nclass ReliableUploader:
\n"""\u5e26\u65ad\u7f51\u7eed\u4f20\u7684 MQTT \u4e0a\u884c\u5c01\u88c5"""
\ndef init(self, host, port=1883, topic="factory\/l1\/telemetry"):
\nimport paho.mqtt.client as mqtt
\nself.topic = topic
\nself.queue = LocalQueue()
\nself.online = False
\nself.client = mqtt.Client(client_id=f"gw-{int(time.time())}")
\nself.client.on_connect = self._on_connect
\nself.client.on_disconnect = self._on_disconnect
\nself.client.connect_async(host, port, keepalive=60) # \u5f02\u6b65\u8fde\u63a5，\u65ad\u7f51\u4e0d\u963b\u585e\u4e3b\u5faa\u73af
\nself.client.loop_start()
\ndef _on_connect(self, client, userdata, flags, rc):
\nself.online = (rc == 0)
\nif self.online:
\nprint("[mqtt] \u5df2\u8fde\u63a5，\u5f00\u59cb\u8865\u53d1\u672c\u5730\u7f13\u5b58")
\nthreading.Thread(target=self._flush, daemon=True).start()
\ndef _on_disconnect(self, client, userdata, rc):
\nself.online = False
\nprint(f"[mqtt] \u8fde\u63a5\u65ad\u5f00 rc={rc}，\u8f6c\u5165\u672c\u5730\u7f13\u5b58\u6a21\u5f0f")
\ndef publish(self, ts, payload):
\n"""\u7edf\u4e00\u5165\u53e3：\u65e0\u8bba\u5728\u7ebf\u4e0e\u5426，\u5148\u843d\u672c\u5730，\u518d\u5c1d\u8bd5\u53d1\u9001"""
\nself.queue.put(ts, self.topic, payload)
\nif self.online:
\nself._flush()
\ndef _flush(self):
\n"""\u6309\u65f6\u95f4\u987a\u5e8f\u8865\u53d1，\u53d1\u9001\u6210\u529f\u624d ack \u5220\u9664"""
\nwhile self.online:
\nrows = self.queue.peek_batch()
\nif not rows:
\nreturn
\nok_ids = []
\nfor rid, ts, topic, payload in rows:
\ninfo = self.client.publish(topic, payload, qos=1)
\n# wait_for_publish \u786e\u8ba4 broker \u5df2\u63a5\u6536，\u907f\u514d\u201c\u5047\u6210\u529f\u201d\u4e22\u6570\u636e
\ntry:
\ninfo.wait_for_publish(timeout=5)
\nif info.is_published():
\nok_ids.append(rid)
\nelse:
\nbreak
\nexcept Exception:
\nself.online = False
\nbreak
\nself.queue.ack(ok_ids)
\nif not self.online:
\nreturn
\n———- \u843d\u5e93\u4fa7：qos=1 \u91cd\u590d\u6570\u636e\u7684\u5e42\u7b49\u53bb\u91cd ———-
\ndef init_sink(conn):
\n"""ts + point \u8054\u5408\u4e3b\u952e，\u5929\u7136\u5e42\u7b49：\u91cd\u590d\u5199\u5165\u53ea\u4f1a\u8986\u76d6，\u4e0d\u4f1a\u4ea7\u751f\u810f\u6570\u636e"""
\nconn.execute("""
\nCREATE TABLE IF NOT EXISTS raw (
\nts TEXT NOT NULL, — \u4e0e\u4e0a\u884c payload \u4e2d\u7684 ts \u5b8c\u5168\u4e00\u81f4
\npoint TEXT NOT NULL,
\nvalue REAL,
\nPRIMARY KEY (ts, point)
\n)
\n""")
\nconn.commit()
\ndef write_idempotent(conn, rows):
\n"""rows: [(ts, point, value), …]
\nqos=1 \u4e0b\u540c\u4e00\u6761\u6570\u636e\u53ef\u80fd\u88ab\u6295\u9012\u591a\u6b21，INSERT OR REPLACE \u4fdd\u8bc1\u7ed3\u679c\u4e00\u81f4\u3002
\n"""
\nconn.executemany(
\n"INSERT OR REPLACE INTO raw (ts, point, value) VALUES (?, ?, ?)", rows
\n)
\nconn.commit()
\nif name == "main":
\nup = ReliableUploader(host="127.0.0.1")
\nwhile True:
\nts = time.strftime("%Y-%m-%dT%H:%M:%S", time.gmtime()) + ".000Z"
\nup.publish(ts, {"ts": ts, "data": [{"point": "SH01.LINE_A.CNC.01.PROCESS.spindle_load", "value": 62.5}]})
\nprint(f"[{ts}] \u672c\u5730\u5f85\u8865\u53d1 {up.queue.pending()} \u6761")
\ntime.sleep(1) <\/p>\n \u51e0\u4e2a\u5bb9\u6613\u5ffd\u7565\u7684\u7ec6\u8282：<\/p>\n \n- \u5148\u843d\u76d8\u518d\u53d1\u9001，\u800c\u4e0d\u662f\u53d1\u9001\u5931\u8d25\u518d\u843d\u76d8\u3002\u540e\u8005\u5728\u8fdb\u7a0b\u88ab kill \u6216\u6389\u7535\u65f6\u4f1a\u4e22\u6389\u6b63\u5728\u53d1\u9001\u7684\u90a3\u4e00\u6279\u3002<\/li>\n
- ack \u4e4b\u524d\u5d29\u6e83\u4f1a\u91cd\u53d1，\u8fd9\u662f\u6709\u610f\u4e3a\u4e4b\u2014\u2014\u5b81\u53ef\u91cd\u590d，\u4e0d\u53ef\u4e22\u5931\u3002\u91cd\u590d\u7531\u4e0b\u6e38 (ts, point) \u4e3b\u952e\u515c\u4f4f\u3002<\/li>\n
- \u8865\u53d1\u8981\u9650\u901f\u3002\u65ad\u7f51\u4e24\u5c0f\u65f6\u53ef\u80fd\u79ef\u538b\u51e0\u5341\u4e07\u6761，\u91cd\u8fde\u540e\u4e00\u6b21\u6027\u704c\u8fdb\u53bb\u4f1a\u628a broker \u548c\u65f6\u5e8f\u5e93\u6253\u6ee1，\u6240\u4ee5\u7528 BATCH_SIZE \u5206\u6279，\u5fc5\u8981\u65f6\u52a0 sleep\u3002<\/li>\n
- \u73af\u5f62\u5bb9\u91cf\u8981\u7b97\u6e05\u695a\u300250 \u4e07\u6761\u6309\u6bcf\u79d2 100 \u6761\u7b97\u7ea6 1.4 \u5c0f\u65f6，\u5982\u679c\u73b0\u573a\u65ad\u7f51\u53ef\u80fd\u8d85\u8fc7\u8fd9\u4e2a\u65f6\u957f，\u5c31\u8981\u8c03\u5927 MAX_ROWS \u6216\u964d\u4f4e\u91c7\u96c6\u9891\u7387\u3002<\/li>\n<\/ul>\n
5.2 \u843d\u5e93\u4e0e\u964d\u91c7\u6837<\/h4>\n\u65f6\u5e8f\u6570\u636e\u843d\u5730\u540e，\u771f\u6b63\u51b3\u5b9a\u8fd9\u5957\u7cfb\u7edf\u80fd\u6d3b\u591a\u4e45\u7684\u662f\u964d\u91c7\u6837\u7b56\u7565\u3002\u539f\u59cb\u6570\u636e\u4fdd\u7559\u77ed\u671f，\u805a\u5408\u6570\u636e\u4fdd\u7559\u957f\u671f，\u5426\u5219\u534a\u5e74\u540e\u67e5\u8be2\u6027\u80fd\u4f1a\u5d29\u6389\u3002<\/p>\n # -*- coding: utf-8 -*-
\n"""
\n\u65f6\u5e8f\u6570\u636e\u843d\u5e93\u4e0e\u964d\u91c7\u6837\u793a\u4f8b（SQLite \u7248，\u96f6\u5916\u90e8\u4f9d\u8d56\u5373\u53ef\u8fd0\u884c）
\n\u751f\u4ea7\u73af\u5883\u53ef\u66ff\u6362\u4e3a InfluxDB \/ TDengine，\u903b\u8f91\u4e00\u81f4\u3002
\n"""
\nimport sqlite3
\nimport time
\nfrom datetime import datetime, timedelta
\nDB = "telemetry.db"
\ndef init_db(conn):
\nconn.execute("""
\nCREATE TABLE IF NOT EXISTS raw (
\nts INTEGER NOT NULL, — \u6beb\u79d2\u65f6\u95f4\u6233
\npoint TEXT NOT NULL, — \u70b9\u4f4d\u5168\u540d
\nvalue REAL,
\nPRIMARY KEY (ts, point)
\n)
\n""")
\nconn.execute("""
\nCREATE TABLE IF NOT EXISTS agg_1m (
\nts INTEGER NOT NULL, — \u5bf9\u9f50\u5230\u5206\u949f
\npoint TEXT NOT NULL,
\nv_avg REAL, v_min REAL, v_max REAL, v_cnt INTEGER,
\nPRIMARY KEY (ts, point)
\n)
\n""")
\nconn.execute("CREATE INDEX IF NOT EXISTS idx_raw_point ON raw(point, ts)")
\nconn.commit()
\ndef write_batch(conn, rows):
\n"""rows: [(ts_ms, point, value), …]"""
\nconn.executemany(
\n"INSERT OR REPLACE INTO raw (ts, point, value) VALUES (?, ?, ?)", rows
\n)
\nconn.commit()
\ndef rollup_to_1m(conn, end_ms, window_min=1):
\n"""\u628a\u7a97\u53e3\u5185\u7684\u539f\u59cb\u6570\u636e\u805a\u5408\u4e3a\u5206\u949f\u7ea7，\u5e76\u5220\u9664\u5df2\u805a\u5408\u7684\u539f\u59cb\u6570\u636e"""
\nstart_ms = end_ms – window_min * 60 * 1000
\ncur = conn.execute("""
\nSELECT point,
\nAVG(value), MIN(value), MAX(value), COUNT(*)
\nFROM raw WHERE ts >= ? AND ts < ? GROUP BY point
\n""", (start_ms, end_ms))
\nagg = cur.fetchall()
\nminute_ts = (end_ms \/\/ 60000) * 60000
\nconn.executemany(
\n"INSERT OR REPLACE INTO agg_1m (ts, point, v_avg, v_min, v_max, v_cnt) "
\n"VALUES (?, ?, ?, ?, ?, ?)",
\n[(minute_ts, p, a, mi, ma, c) for p, a, mi, ma, c in agg]
\n)
\nconn.execute("DELETE FROM raw WHERE ts >= ? AND ts < ?", (start_ms, end_ms))
\nconn.commit()
\nreturn len(agg)
\ndef query_trend(conn, point, hours=8):
\n"""\u67e5\u8be2\u8fd1 N \u5c0f\u65f6\u8d8b\u52bf：\u4f18\u5148\u8d70\u805a\u5408\u8868，\u8fd9\u662f\u770b\u677f\u80fd\u79d2\u5f00\u7684\u539f\u56e0"""
\nsince = int((datetime.utcnow() – timedelta(hours=hours)).timestamp() * 1000)
\ncur = conn.execute(
\n"SELECT ts, v_avg FROM agg_1m WHERE point = ? AND ts >= ? ORDER BY ts",
\n(point, since)
\n)
\nreturn cur.fetchall()
\nif name == "main":
\nconn = sqlite3.connect(DB)
\ninit_db(conn)
\n# \u6a21\u62df\u5199\u5165 120 \u79d2\u6570\u636e（\u6bcf\u79d2\u4e00\u4e2a\u70b9）
\nnow = int(time.time() * 1000)
\nrows = []
\nfor i in range(120):
\n ts = now – (120 – i) * 1000
\n rows.append((ts, "SH01.LINE_A.CNC.01.PROCESS.spindle_load", 40 + i % 30))
\nwrite_batch(conn, rows)
\nprint("\u5199\u5165\u539f\u59cb\u70b9\u4f4d\u6570:", len(rows))
\n\u805a\u5408\u4e3a\u5206\u949f\u7ea7
\nn = rollup_to_1m(conn, now, window_min=5)
\nprint("\u805a\u5408\u70b9\u4f4d:", n)
\n\u67e5\u8be2\u8d8b\u52bf
\ntrend = query_trend(conn, "SH01.LINE_A.CNC.01.PROCESS.spindle_load")
\nprint("\u8d8b\u52bf\u70b9\u6570:", len(trend), "\u793a\u4f8b:", trend[:3])
\nconn.close()<\/code><\/pre>
\n\u8fd9\u6bb5\u4ee3\u7801\u8dd1\u8d77\u6765\u4e0d\u9700\u8981\u4efb\u4f55\u5916\u90e8\u670d\u52a1，\u5efa\u8bae\u5148\u5728\u7b14\u8bb0\u672c\u4e0a\u628a\u94fe\u8def\u8d70\u4e00\u904d，\u518d\u63a5\u5230\u771f\u5b9e\u8bbe\u5907\u4e0a\u3002\u987a\u5e8f\u5f88\u91cd\u8981：\u5148\u9a8c\u8bc1\u94fe\u8def，\u518d\u63a5\u8bbe\u5907，\u53cd\u8fc7\u6765\u505a\u4f1a\u5728\u73b0\u573a\u6d6a\u8d39\u5927\u91cf\u65f6\u95f4\u3002
\n\u516d\u3001\u4e09\u4e2a\u771f\u5b9e\u4f1a\u8e29\u7684\u5751
\n\u5751\u4e00：\u8001\u65e7\u8bbe\u5907\u6ca1\u6709\u7f51\u53e3\u3002
\n\u5341\u5e74\u524d\u7684 CNC \u53ea\u6709 RS-232 \u4e32\u53e3，\u6216\u8005\u8fde PLC \u90fd\u6ca1\u6709\u3002\u53ef\u884c\u505a\u6cd5\u6709\u4e09\u6863：\u6709\u4e32\u53e3\u7684\u8d70 Modbus RTU \u8f6c\u7f51\u5173；\u53ea\u6709 IO \u4fe1\u53f7\u7684\u7528 IO \u6a21\u5757\u91c7\u8fd0\u884c\u72b6\u6001；\u8fde\u72b6\u6001\u90fd\u91c7\u4e0d\u5230\u7684，\u7528\u5916\u63a5\u7535\u6d41\u4e92\u611f\u5668\u6d4b\u6574\u673a\u529f\u7387，\u53cd\u63a8\u8fd0\u884c\/\u5f85\u673a\/\u505c\u673a\u2014\u2014\u8fd9\u4e0d\u662f\u53d6\u5de7，\u800c\u662f\u5f88\u591a\u8001\u4ea7\u7ebf\u552f\u4e00\u80fd\u843d\u5730\u7684\u65b9\u6848，\u7cbe\u5ea6\u4e5f\u591f\u7528\u6765\u7b97 OEE（\u8bbe\u5907\u7efc\u5408\u6548\u7387，Overall Equipment Effectiveness）\u3002
\n\u5751\u4e8c：\u70b9\u4f4d\u547d\u540d\u6ca1\u6709\u6807\u51c6\u3002
\n\u540c\u4e00\u53f0\u6ce8\u5851\u673a，\u5728\u8bbe\u5907\u53f0\u8d26\u91cc\u53eb"IM-03"，\u5728\u7535\u5de5\u53e3\u91cc\u53eb"\u4e09\u53f7\u673a"，\u5728 MES \u91cc\u53eb"INJ_003"\u3002\u4e09\u4e2a\u540d\u5b57\u6307\u5411\u540c\u4e00\u53f0\u8bbe\u5907，\u4efb\u4f55\u8de8\u7cfb\u7edf\u5bf9\u8d26\u90fd\u8981\u4eba\u5de5\u7ffb\u8bd1\u3002\u5148\u5efa\u70b9\u4f4d\u5b57\u5178\u518d\u91c7\u96c6，\u547d\u540d\u89c4\u5219\u53c2\u8003\u524d\u6587 make_point()，\u5168\u5382\u7edf\u4e00\u4e00\u6b21，\u540e\u9762\u6240\u6709\u7cfb\u7edf\u90fd\u53d7\u76ca\u3002
\n\u5751\u4e09：\u6ca1\u6709\u964d\u91c7\u6837\u7b56\u7565\u3002
\n\u524d\u9762\u7ed9\u4e86 rollup_to_1m() \u7684\u5b9e\u73b0\u3002\u6ca1\u6709\u5b83，\u79d2\u7ea7\u539f\u59cb\u6570\u636e\u5b58\u4e00\u5e74，\u67e5\u8be2\u4f1a\u4ece\u79d2\u7ea7\u9000\u5316\u5230\u5206\u949f\u7ea7，\u770b\u677f\u6253\u4e0d\u5f00，\u5de5\u7a0b\u5e08\u5c31\u5f00\u59cb\u6000\u7591\u8fd9\u5957\u7cfb\u7edf\u7684\u4ef7\u503c\u3002\u539f\u59cb 30 \u5929 + \u5206\u949f\u7ea7 2 \u5e74 + \u5c0f\u65f6\u7ea7 5 \u5e74，\u662f\u5927\u591a\u6570\u4e2d\u5c0f\u5382\u591f\u7528\u7684\u914d\u6bd4\u3002
\n\u4e03\u3001\u843d\u5730\u68c0\u67e5\u6e05\u5355
\n\u3010\u914d\u56fe\u4f4d\u7f6e2\u3011\u8bf7\u5728\u6b64\u4e0a\u4f20 \u56fe2_\u843d\u5730\u68c0\u67e5\u6e05\u5355.png
\n\u6309\u8fd9\u4e2a\u987a\u5e8f\u63a8\u8fdb，\u53ef\u4ee5\u5c11\u8d70\u5f88\u591a\u5f2f\u8def：
\n\u76d8\u70b9\u8bbe\u5907\u6e05\u5355：\u578b\u53f7\u3001\u51fa\u5382\u5e74\u4efd\u3001\u63a7\u5236\u5668\u7c7b\u578b\u3001\u53ef\u63d0\u4f9b\u7684\u63a5\u53e3（\u7f51\u53e3 \/ \u4e32\u53e3 \/ IO \/ \u65e0）
\n\u786e\u5b9a\u4e09\u5c42\u6570\u636e\u8303\u56f4：L1 \u91c7\u54ea\u4e9b\u3001L2 \u91c7\u54ea\u4e9b\u3001L3 \u600e\u4e48\u8ddf\u5de5\u5355\u7ed1\u5b9a，\u5148\u505a\u51cf\u6cd5
\n\u5efa\u7acb\u70b9\u4f4d\u5b57\u5178：\u5168\u5382\u7edf\u4e00\u547d\u540d，\u4e00\u6b21\u5230\u4f4d
\n\u786e\u8ba4\u91c7\u96c6\u9891\u7387：L1 \u79d2\u7ea7\u3001L2 \u79d2\u5230\u5206\u949f\u7ea7\u3001L3 \u4e8b\u4ef6\u89e6\u53d1，\u4e0d\u8981\u4e00\u5f8b\u6700\u9ad8\u9891
\n\u9009\u5b9a\u5b58\u50a8\u65b9\u6848：\u65f6\u5e8f\u5e93\u9009\u578b + \u964d\u91c7\u6837\u914d\u6bd4 + \u5907\u4efd\u7b56\u7565
\n\u660e\u786e\u6570\u636e\u8fb9\u754c：\u54ea\u4e9b\u5728\u5382\u5185\u3001\u54ea\u4e9b\u53ef\u5916\u9001\u3001\u8c01\u80fd\u8bbf\u95ee
\n\u5148\u8dd1\u901a\u4e00\u6761\u4ea7\u7ebf：\u4e00\u6761\u7ebf\u8dd1\u987a\u518d\u590d\u5236，\u4e0d\u8981\u5168\u5382\u94fa\u5f00
\n\u9a8c\u6536\u6807\u51c6\u5199\u8fdb\u5408\u540c：\u91c7\u96c6\u8986\u76d6\u7387\u3001\u6570\u636e\u5b8c\u6574\u7387\u3001\u65ad\u7f51\u7eed\u4f20\u65f6\u957f，\u80fd\u91cf\u5316\u7684\u90fd\u91cf\u5316
\n\u516b\u3001\u5e38\u89c1\u95ee\u9898
\nQ1：\u4e00\u5b9a\u8981\u5148\u4e0a MES \u624d\u80fd\u7b97\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u5417？
\n\u4e0d\u662f\u3002\u653f\u7b56\u5bf9\u57fa\u7840\u7ea7\u7684\u8868\u8ff0\u662f"\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u3001\u5173\u952e\u751f\u4ea7\u5de5\u5e8f\u81ea\u52a8\u5316\u3001\u751f\u4ea7\u4e0e\u7ecf\u8425\u7ba1\u7406\u4fe1\u606f\u5316"\u4e09\u4ef6\u4e8b\u5e76\u5217，\u91c7\u96c6\u662f\u5176\u4e2d\u4e4b\u4e00，\u5e76\u4e0d\u4ee5 MES \u4e3a\u524d\u7f6e\u6761\u4ef6\u3002\u5b9e\u9645\u5de5\u7a0b\u4e2d，\u5148\u628a\u8bbe\u5907\u6570\u636e\u91c7\u4e0a\u6765\u3001\u5b58\u597d\u3001\u80fd\u7528，\u53cd\u800c\u80fd\u4e3a\u540e\u7eed MES \u9009\u578b\u63d0\u4f9b\u66f4\u771f\u5b9e\u7684\u4f9d\u636e\u2014\u2014\u81f3\u5c11\u4f60\u77e5\u9053\u81ea\u5df1\u5230\u5e95\u8981\u7ba1\u4ec0\u4e48\u3002
\nQ2：\u91c7\u96c6\u9891\u7387\u662f\u4e0d\u662f\u8d8a\u9ad8\u8d8a\u597d？
\n\u4e0d\u662f\u3002\u9891\u7387\u8981\u5339\u914d\u4e1a\u52a1\u95ee\u9898：\u7b97 OEE \u7528\u79d2\u7ea7\u8db3\u591f，\u5206\u6790\u5de5\u827a\u6f02\u79fb\u5206\u949f\u7ea7\u8db3\u591f，\u505a\u5200\u5177\u5bff\u547d\u9884\u6d4b\u53ef\u80fd\u8981\u4e9a\u79d2\u7ea7\u3002\u6309\u95ee\u9898\u5b9a\u9891\u7387，\u9ad8\u9891\u6570\u636e\u7684\u5b58\u50a8\u4e0e\u8ba1\u7b97\u6210\u672c\u662f\u6301\u7eed\u7684，\u4e0d\u662f\u4e00\u6b21\u6027\u7684\u3002
\nQ3：\u8981\u6c42\u6570\u636e\u4e0d\u51fa\u5382，\u8fd8\u80fd\u505a AI \u5206\u6790\u5417？
\n\u80fd，\u800c\u4e14\u8fd9\u662f\u66f4\u5e38\u89c1\u7684\u90e8\u7f72\u65b9\u5f0f\u3002\u91c7\u96c6\u3001\u5b58\u50a8\u3001\u6a21\u578b\u63a8\u7406\u5168\u90e8\u653e\u5728\u5382\u5185，\u53ea\u6709\u9700\u8981\u8de8\u5382\u534f\u540c\u7684\u805a\u5408\u7ed3\u679c（\u6bd4\u5982\u96c6\u56e2\u7ea7\u4ea7\u80fd\u770b\u677f）\u624d\u5916\u9001\u3002\u79c1\u6709\u5316\u90e8\u7f72\u7684\u6280\u672f\u6808\u5df2\u7ecf\u5f88\u6210\u719f，\u9700\u8981\u6743\u8861\u7684\u662f\u7b97\u529b\u6210\u672c，\u4e0d\u662f\u53ef\u884c\u6027\u3002
\nQ4：1600 \u5bb6\u57fa\u7840\u7ea7\u7684"\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6"\u6709\u6ca1\u6709\u91cf\u5316\u6807\u51c6？
\n\u76ee\u524d\u516c\u5f00\u8868\u8ff0\u4e2d\u6ca1\u6709\u7ed9\u51fa\u70b9\u4f4d\u6570\u91cf\u3001\u91c7\u96c6\u9891\u7387\u7684\u5177\u4f53\u9608\u503c，\u53ea\u660e\u786e\u4e86"\u5b9e\u65f6\u91c7\u96c6"\u8fd9\u4e2a\u6027\u8d28\u8981\u6c42\u3002\u5de5\u7a0b\u4e0a\u7684\u5224\u65ad\u4f9d\u636e\u662f：\u91c7\u5230\u7684\u6570\u636e\u80fd\u5426\u56de\u7b54"\u8bbe\u5907\u73b0\u5728\u80fd\u4e0d\u80fd\u5e72\u6d3b""\u8fd9\u9053\u5de5\u5e8f\u7a33\u4e0d\u7a33""\u8fd9\u6279\u6d3b\u5e72\u5f97\u600e\u4e48\u6837"\u8fd9\u4e09\u4e2a\u95ee\u9898\u3002\u80fd\u56de\u7b54，\u5c31\u8fbe\u5230\u4e86\u57fa\u7840\u7ea7\u8fd9\u4e00\u6b65\u7684\u5b9e\u8d28\u8981\u6c42\u3002
\n\u4e5d\u3001\u603b\u7ed3
\n\u56de\u5230\u653f\u7b56\u90a3\u4e09\u53e5\u8bdd\u3002\u57fa\u7840\u7ea7 1600 \u5bb6\u8fd9\u4e2a\u91cf\u7ea7\u610f\u5473\u7740，\u7edd\u5927\u591a\u6570\u5de5\u5382\u8981\u8de8\u7684\u7b2c\u4e00\u6b65\u4e0d\u662f\u9009\u5927\u6a21\u578b\u3001\u4e0d\u662f\u4e70\u673a\u5668\u4eba，\u800c\u662f\u628a\u8f66\u95f4\u91cc\u90a3\u4e9b\u5df2\u7ecf\u5b58\u5728\u4e86\u5341\u5e74\u3001\u4e8c\u5341\u5e74\u7684\u8bbe\u5907\u6570\u636e，\u7a33\u5b9a\u3001\u5b8c\u6574\u3001\u53ef\u8ffd\u6eaf\u5730\u91c7\u4e0a\u6765\u3002
\n\u8fd9\u4e00\u5c42\u7684\u95e8\u69db\u4e0d\u9ad8，\u4f46\u5f88\u5b9e：\u9700\u8981\u7684\u662f\u70b9\u4f4d\u5b57\u5178\u3001\u91c7\u96c6\u94fe\u8def\u3001\u65f6\u5e8f\u5b58\u50a8\u548c\u964d\u91c7\u6837\u7b56\u7565，\u800c\u4e0d\u662f\u6982\u5ff5\u3002\u628a\u8fd9\u4e00\u5c42\u505a\u624e\u5b9e，\u4e0a\u9762\u90a3\u4e9b AI \u573a\u666f\u624d\u6709\u7740\u843d；\u8df3\u8fc7\u8fd9\u4e00\u5c42\u76f4\u63a5\u8c08\u667a\u80fd\u4f53，\u6700\u540e\u5f80\u5f80\u505c\u5728\u6f14\u793a\u91cc\u3002
\n\u53c2\u8003\u4e0e\u8bf4\u660e
\n\u653f\u7b56\u6765\u6e90：\u300a\u4e0a\u6d77\u5e02\u52a0\u5feb\u53d1\u5c55\u65b0\u4e00\u4ee3\u667a\u80fd\u5236\u9020\u884c\u52a8\u65b9\u6848\u300b，\u4e0a\u6d77\u5e02\u7ecf\u6d4e\u4fe1\u606f\u5316\u59d4，2026 \u5e74 10 \u6708 27 \u65e5\u5370\u53d1；2026 \u5e74 10 \u6708 28 \u65e5\u7ecf\u4e2d\u56fd\u65b0\u95fb\u7f51\u3001\u8bc1\u5238\u65f6\u62a5\u3001\u6f8e\u6e43\u65b0\u95fb\u7b49\u5a92\u4f53\u62a5\u9053\u3002\u6587\u4e2d\u5f15\u7528\u7684\u6570\u5b57\u5747\u6765\u81ea\u4e0a\u8ff0\u516c\u5f00\u62a5\u9053\u3002
\n\u5229\u76ca\u76f8\u5173：\u672c\u4eba\u4ece\u4e8b\u5de5\u5382 AI \u7cfb\u7edf\u7684\u843d\u5730\u5de5\u4f5c，\u6587\u4e2d\u67b6\u6784\u4e0e\u4ee3\u7801\u6765\u81ea\u5b9e\u9645\u90e8\u7f72\u8fc7\u7684\u9879\u76ee，\u5ba2\u6237\u540d\u79f0\u4e0e\u5177\u4f53\u6570\u636e\u56e0\u672a\u83b7\u516c\u5f00\u6388\u6743\u5df2\u505a\u8131\u654f，\u793a\u4f8b\u4ee3\u7801\u4e3a\u8131\u654f\u540e\u7684\u7b80\u5316\u7248\u672c\u3002
\n\u8bf4\u660e：\u672c\u6587\u5199\u4f5c\u8fc7\u7a0b\u4e2d\u4f7f\u7528\u4e86 AI \u5de5\u5177\u8f85\u52a9\u6574\u7406\u8d44\u6599\u4e0e\u6821\u5bf9，\u6280\u672f\u5224\u65ad\u4e0e\u73b0\u573a\u7ecf\u9a8c\u7531\u672c\u4eba\u8d1f\u8d23\u3002\u6587\u4e2d\u7684\u653f\u7b56\u5f15\u7528\u53ef\u81ea\u884c\u6838\u9a8c\u3002 <\/p>\n 5.3 \u4ece\u91c7\u96c6\u6570\u636e\u7b97 OEE<\/h4>\n\u6570\u636e\u91c7\u4e0a\u6765\u3001\u5b58\u597d\u4e86，\u63a5\u4e0b\u6765\u8981\u56de\u7b54\u4e00\u4e2a\u8001\u677f\u6700\u5173\u5fc3\u7684\u95ee\u9898：\u8fd9\u5957\u8bbe\u5907\u5230\u5e95\u6709\u591a\u5c11\u6709\u6548\u4ea7\u51fa\u3002OEE（\u8bbe\u5907\u7efc\u5408\u6548\u7387，Overall Equipment Effectiveness）\u5c31\u662f\u6807\u51c6\u7b54\u6848，\u5b83\u7531\u4e09\u4e2a\u56e0\u5b50\u76f8\u4e58\u5f97\u5230：<\/p>\n OEE = \u53ef\u7528\u7387（Availability） \u00d7 \u6027\u80fd\u7387（Performance） \u00d7 \u826f\u54c1\u7387（Quality） <\/p>\n \u4e09\u4e2a\u56e0\u5b50\u5206\u522b\u5bf9\u5e94\u524d\u6587\u4e09\u7ea7\u6e05\u5355\u91cc\u7684\u4e0d\u540c\u5c42，\u8fd9\u4e5f\u662f\u4e3a\u4ec0\u4e48\u4e09\u5c42\u90fd\u8981\u91c7：<\/p>\n \nOEE \u56e0\u5b50\u8ba1\u7b97\u516c\u5f0f\u4f9d\u8d56\u7684\u6570\u636e\u5c42\u5177\u4f53\u70b9\u4f4d<\/tr>\n \n\n| \u53ef\u7528\u7387 A<\/td>\n | \u5b9e\u9645\u8fd0\u884c\u65f6\u95f4 \/ \u8ba1\u5212\u751f\u4ea7\u65f6\u95f4<\/td>\n | L1 \u8bbe\u5907\u8fd0\u884c\u72b6\u6001<\/td>\n | STATUS.state（RUN \/ IDLE \/ ALARM）<\/td>\n<\/tr>\n | \n| \u6027\u80fd\u7387 P<\/td>\n | \u7406\u8bba\u8282\u62cd \u00d7 \u5b9e\u9645\u4ea7\u51fa \/ \u5b9e\u9645\u8fd0\u884c\u65f6\u95f4<\/td>\n | L2 \u5de5\u5e8f\u8fc7\u7a0b\u91cf<\/td>\n | PROCESS.cycle_time（\u5b9e\u9645\u8282\u62cd）<\/td>\n<\/tr>\n | \n| \u826f\u54c1\u7387 Q<\/td>\n | \u5408\u683c\u6570 \/ \u603b\u4ea7\u51fa\u6570<\/td>\n | L3 \u4ea7\u51fa\u4e0e\u8d28\u91cf\u7ed3\u679c<\/td>\n | \u5408\u683c\u6570\u3001\u4e0d\u5408\u683c\u6570（\u62a5\u5de5\u6216\u89c6\u89c9\u68c0\u6d4b）<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n \u4e00\u53e5\u8bdd\u8bb0\u6cd5：L1 \u51b3\u5b9a\u673a\u5668\u8f6c\u4e0d\u8f6c，L2 \u51b3\u5b9a\u8f6c\u5f97\u5feb\u4e0d\u5feb，L3 \u51b3\u5b9a\u8f6c\u51fa\u6765\u7684\u6d3b\u597d\u4e0d\u597d\u3002\u7f3a\u4efb\u4f55\u4e00\u5c42，OEE \u90fd\u7b97\u4e0d\u51fa\u6765\u2014\u2014\u53ea\u6709 L1 \u80fd\u7b97\u53ef\u7528\u7387，\u53ea\u6709 L1+L2 \u80fd\u7b97\u6027\u80fd\u548c\u53ef\u7528\u7387，\u4e09\u5c42\u9f50\u5168\u624d\u662f\u5b8c\u6574\u7684 OEE\u3002<\/p>\n \u4e0b\u9762\u8fd9\u6bb5\u4ee3\u7801\u76f4\u63a5\u590d\u7528 5.2 \u91cc\u7684 raw \u4e0e agg_1m \u4e24\u5f20\u8868，\u96f6\u5916\u90e8\u4f9d\u8d56\u5373\u53ef\u8fd0\u884c：<\/p>\n # -*- coding: utf-8 -*-
\n"""
\n\u4ece\u91c7\u96c6\u6570\u636e\u8ba1\u7b97 OEE：\u53ef\u7528\u7387 \u00d7 \u6027\u80fd\u7387 \u00d7 \u826f\u54c1\u7387
\n\u4f9d\u8d56：\u4ec5\u6807\u51c6\u5e93，\u590d\u7528 5.2 \u7684 raw \/ agg_1m \u4e24\u5f20\u8868
\n\u8bf4\u660e：L3 \u7684\u4ea7\u51fa\u4e0e\u8d28\u91cf\u6570\u636e\u5728\u771f\u5b9e\u9879\u76ee\u91cc\u6765\u81ea MES \u62a5\u5de5\u6216\u89c6\u89c9\u68c0\u6d4b，
\n \u8fd9\u91cc\u7528\u4e00\u5f20 production \u8868\u6a21\u62df，\u5b57\u6bb5\u4e0e MES \u4fa7\u4fdd\u6301\u4e00\u81f4\u3002
\n"""
\nimport sqlite3
\nimport time
\nDB = "telemetry.db"
\nPOINT_PREFIX = "SH01.LINE_A.CNC.01"
\nIDEAL_CYCLE_TIME = 50.0 # \u7406\u8bba\u8282\u62cd（\u79d2\/\u4ef6），\u6765\u81ea\u5de5\u827a\u6587\u4ef6\u6216\u8bbe\u5907\u989d\u5b9a\u503c
\nPLANNED_MINUTES = 60 # \u7edf\u8ba1\u7a97\u53e3：\u8ba1\u5212\u751f\u4ea7 60 \u5206\u949f
\ndef init_production(conn):
\n"""L3 \u4ea7\u51fa\u4e0e\u8d28\u91cf\u7ed3\u679c：\u771f\u5b9e\u573a\u666f\u7531 MES \u62a5\u5de5\u6216\u89c6\u89c9\u68c0\u6d4b\u5199\u5165"""
\nconn.execute("""
\nCREATE TABLE IF NOT EXISTS production (
\nts INTEGER NOT NULL, — \u62a5\u5de5\u65f6\u95f4（\u6beb\u79d2）
\ndevice TEXT NOT NULL, — \u8bbe\u5907\u7f16\u53f7
\ngood_count INTEGER NOT NULL, — \u5408\u683c\u6570
\nbad_count INTEGER NOT NULL, — \u4e0d\u5408\u683c\u6570
\nPRIMARY KEY (ts, device)
\n)
\n""")
\nconn.commit()
\ndef calc_availability(conn, prefix, start_ms, end_ms, planned_minutes):
\n"""\u53ef\u7528\u7387 A = \u5b9e\u9645\u8fd0\u884c\u65f6\u95f4 \/ \u8ba1\u5212\u751f\u4ea7\u65f6\u95f4
\n\u6570\u636e\u6765\u6e90：L1 \u8bbe\u5907\u8fd0\u884c\u72b6\u6001，\u4ece agg_1m \u91cc\u53d6 state \u7684\u5206\u949f\u7ea7\u6837\u672c\u3002
\n\u7ea6\u5b9a：state \u70b9\u4f4d value=1 \u8868\u793a RUN，0 \u8868\u793a\u975e RUN（IDLE\/ALARM\/\u505c\u673a）\u3002
\n"""
\ncur = conn.execute("""
\nSELECT SUM(v_avg * v_cnt) \/ NULLIF(SUM(v_cnt), 0)
\nFROM agg_1m
\nWHERE point = ? AND ts >= ? AND ts < ?
\n""", (f"{prefix}.STATUS.state", start_ms, end_ms))
\nrow = cur.fetchone()
\nrun_ratio = row[0] if row and row[0] is not None else 0.0
\nplanned_ms = planned_minutes * 60 * 1000
\nrun_ms = run_ratio * planned_ms
\nreturn run_ms, planned_ms, (run_ms \/ planned_ms if planned_ms else 0.0)
\ndef calc_performance(conn, prefix, start_ms, end_ms, run_ms, ideal_cycle):
\n"""\u6027\u80fd\u7387 P = \u7406\u8bba\u8282\u62cd \u00d7 \u5b9e\u9645\u4ea7\u51fa \/ \u5b9e\u9645\u8fd0\u884c\u65f6\u95f4
\n\u6570\u636e\u6765\u6e90：L2 \u5de5\u5e8f\u8fc7\u7a0b\u91cf，\u5b9e\u9645\u8282\u62cd\u53d6 agg_1m \u7684\u52a0\u6743\u5747\u503c\u3002
\n\u5b9e\u9645\u4ea7\u51fa = \u5b9e\u9645\u8fd0\u884c\u65f6\u95f4 \/ \u5b9e\u9645\u5e73\u5747\u8282\u62cd\u3002
\n"""
\ncur = conn.execute("""
\nSELECT SUM(v_avg * v_cnt) \/ NULLIF(SUM(v_cnt), 0)
\nFROM agg_1m
\nWHERE point = ? AND ts >= ? AND ts < ?
\n""", (f"{prefix}.PROCESS.cycle_time", start_ms, end_ms))
\nrow = cur.fetchone()
\nactual_cycle = row[0] if row and row[0] is not None else 0.0
\nif actual_cycle <= 0 or run_ms <= 0:
\nreturn 0.0, 0.0, 0.0
\nactual_output = run_ms \/ 1000.0 \/ actual_cycle # \u5b9e\u9645\u4ea7\u51fa\u4ef6\u6570
\nperformance = (ideal_cycle * actual_output) \/ (run_ms \/ 1000.0)
\nreturn actual_cycle, actual_output, min(performance, 1.0) # \u4e0a\u9650\u622a\u65ad\u5230 1
\ndef calc_quality(conn, device, start_ms, end_ms):
\n"""\u826f\u54c1\u7387 Q = \u5408\u683c\u6570 \/ \u603b\u4ea7\u51fa\u6570
\n\u6570\u636e\u6765\u6e90：L3 \u4ea7\u51fa\u4e0e\u8d28\u91cf\u7ed3\u679c，\u6765\u81ea production \u8868（MES \u62a5\u5de5）\u3002
\n"""
\ncur = conn.execute("""
\nSELECT SUM(good_count), SUM(good_count + bad_count)
\nFROM production
\nWHERE device = ? AND ts >= ? AND ts < ?
\n""", (device, start_ms, end_ms))
\nrow = cur.fetchone()
\ngood = row[0] or 0
\ntotal = row[1] or 0
\nreturn good, total, (good \/ total if total else 0.0)
\ndef calc_oee(conn, prefix, device, end_ms, planned_minutes=PLANNED_MINUTES,
\nideal_cycle=IDEAL_CYCLE_TIME):
\n"""OEE = A \u00d7 P \u00d7 Q，\u8fd4\u56de\u5b8c\u6574\u660e\u7ec6\u4fbf\u4e8e\u6392\u67e5\u662f\u54ea\u4e00\u9879\u62d6\u540e\u817f"""
\nstart_ms = end_ms – planned_minutes * 60 * 1000
\nrun_ms, planned_ms, a = calc_availability(
\n conn, prefix, start_ms, end_ms, planned_minutes)
\nactual_cycle, output, p = calc_performance(
\n conn, prefix, start_ms, end_ms, run_ms, ideal_cycle)
\ngood, total, q = calc_quality(conn, device, start_ms, end_ms)
\noee = a * p * q
\nreturn {
\n"window": (start_ms, end_ms),
\n"run_minutes": round(run_ms \/ 60000, 2),
\n"planned_minutes": planned_minutes,
\n"actual_cycle": round(actual_cycle, 2),
\n"ideal_cycle": ideal_cycle,
\n"output": round(output, 1),
\n"good": good,
\n"total": total,
\n"A": round(a, 4),
\n"P": round(p, 4),
\n"Q": round(q, 4),
\n"OEE": round(oee, 4),
\n}
\nif name == "main":
\nconn = sqlite3.connect(DB)
\ninit_production(conn)
\nnow = int(time.time() * 1000)
\nstart = now – PLANNED_MINUTES * 60 * 1000
\n—- \u6a21\u62df\u5199\u5165 L1 \/ L2 \u7684\u5206\u949f\u7ea7\u805a\u5408\u6570\u636e（\u771f\u5b9e\u573a\u666f\u7531 5.2 \u7684 rollup_to_1m \u751f\u6210）—-
\nrows = []
\nfor i in range(PLANNED_MINUTES):
\nts = start + i * 60 * 1000
\n# \u524d 45 \u5206\u949f RUN，\u540e 15 \u5206\u949f\u505c\u673a \u2192 \u53ef\u7528\u7387\u7ea6 0.75
\nstate = 1.0 if i < 45 else 0.0
\nrows.append((ts, f"{POINT_PREFIX}.STATUS.state", state, state, state, 60))
\n# \u5b9e\u9645\u8282\u62cd 55 \u79d2，\u7406\u8bba 50 \u79d2 \u2192 \u6027\u80fd\u7387\u7ea6 0.909
\nrows.append((ts, f"{POINT_PREFIX}.PROCESS.cycle_time", 55.0, 54.0, 56.0, 60))
\nconn.executemany(
\n"INSERT OR REPLACE INTO agg_1m (ts, point, v_avg, v_min, v_max, v_cnt) "
\n"VALUES (?, ?, ?, ?, ?, ?)", rows)
\n—- \u6a21\u62df\u5199\u5165 L3 \u4ea7\u51fa\u4e0e\u8d28\u91cf（\u771f\u5b9e\u573a\u666f\u6765\u81ea MES \u62a5\u5de5）—-
\nconn.execute(
\n"INSERT OR REPLACE INTO production (ts, device, good_count, bad_count) "
\n"VALUES (?, ?, ?, ?)", (now, "CNC.01", 48, 2))
\nconn.commit()
\nresult = calc_oee(conn, POINT_PREFIX, "CNC.01", now)
\nprint("=" * 46)
\nprint(f"\u7edf\u8ba1\u7a97\u53e3：{PLANNED_MINUTES} \u5206\u949f \u8bbe\u5907：CNC.01")
\nprint(f"\u8fd0\u884c\u65f6\u95f4：{result['run_minutes']} \/ {result['planned_minutes']} \u5206\u949f")
\nprint(f"\u5b9e\u9645\u8282\u62cd：{result['actual_cycle']} \u79d2 \u7406\u8bba\u8282\u62cd：{result['ideal_cycle']} \u79d2")
\nprint(f"\u4ea7\u51fa：{result['output']} \u4ef6 \u5408\u683c：{result['good']} \/ {result['total']}")
\nprint("-" * 46)
\nprint(f"\u53ef\u7528\u7387 A = {result['A']:.2%}")
\nprint(f"\u6027\u80fd\u7387 P = {result['P']:.2%}")
\nprint(f"\u826f\u54c1\u7387 Q = {result['Q']:.2%}")
\nprint(f"OEE = {result['OEE']:.2%}")
\nprint("=" * 46)
\nconn.close()<\/code><\/pre>
\n\u793a\u4f8b\u8f93\u51fa（\u6ce8\u91ca\u5f62\u5f0f，\u4fbf\u4e8e\u5bf9\u7167）：
\n\u7edf\u8ba1\u7a97\u53e3：60 \u5206\u949f \u8bbe\u5907：CNC.01
\n\u8fd0\u884c\u65f6\u95f4：45.0 \/ 60 \u5206\u949f
\n\u5b9e\u9645\u8282\u62cd：55.0 \u79d2 \u7406\u8bba\u8282\u62cd：50.0 \u79d2
\n\u4ea7\u51fa：49.1 \u4ef6 \u5408\u683c：48 \/ 50
\n\u53ef\u7528\u7387 A = 75.00%
\n\u6027\u80fd\u7387 P = 90.91%
\n\u826f\u54c1\u7387 Q = 96.00%
\nOEE = 65.45%
\n\u8fd9\u4e2a 65.45% \u5c31\u662f\u5178\u578b\u7684\u300c\u80fd\u770b\u4f46\u4e0d\u591f\u597d\u300d：\u53ef\u7528\u7387 75% \u8bf4\u660e\u505c\u673a\u65f6\u95f4\u5360\u4e86\u56db\u5206\u4e4b\u4e00，\u662f\u6700\u5927\u7684\u77ed\u677f；\u6027\u80fd\u7387 90.91% \u8bf4\u660e\u8282\u62cd\u6bd4\u7406\u8bba\u503c\u6162\u4e86\u7ea6 10%，\u53ef\u80fd\u662f\u5de5\u827a\u53c2\u6570\u504f\u4fdd\u5b88\u6216\u5200\u5177\u78e8\u635f；\u826f\u54c1\u7387 96% \u5df2\u7ecf\u4e0d\u9519\u3002\u6392\u67e5\u987a\u5e8f\u5e94\u8be5\u662f\u5148\u770b A\u3001\u518d\u770b P\u3001\u6700\u540e\u770b Q\u2014\u2014\u505c\u673a\u635f\u5931\u901a\u5e38\u6700\u5bb9\u6613\u6539\u5584，\u4e5f\u6700\u5bb9\u6613\u88ab\u5ffd\u89c6\u3002
\n\u51e0\u4e2a\u843d\u5730\u65f6\u8981\u6ce8\u610f\u7684\u70b9：
\n\u7406\u8bba\u8282\u62cd\u5fc5\u987b\u6765\u81ea\u5de5\u827a\u6587\u4ef6，\u4e0d\u80fd\u62ff\u5386\u53f2\u6700\u5feb\u503c\u5f53\u57fa\u51c6，\u5426\u5219\u6027\u80fd\u7387\u6c38\u8fdc\u63a5\u8fd1 100%，\u5931\u53bb\u8bca\u65ad\u610f\u4e49\u3002
\n\u8ba1\u5212\u751f\u4ea7\u65f6\u95f4\u8981\u6263\u6389\u8ba1\u5212\u505c\u673a（\u6362\u73ed\u3001\u8ba1\u5212\u4fdd\u517b\u3001\u65e0\u6392\u4ea7），\u5426\u5219\u53ef\u7528\u7387\u4f1a\u88ab\u7cfb\u7edf\u6027\u4f4e\u4f30\u3002
\nL3 \u6570\u636e\u8981\u80fd\u5bf9\u4e0a\u5de5\u5355\u3002OEE \u6309\u73ed\u6b21\u3001\u6309\u5de5\u5355\u3001\u6309\u8bbe\u5907\u4e09\u4e2a\u7ef4\u5ea6\u90fd\u8981\u80fd\u5207，\u8fd9\u8981\u6c42 production \u8868\u5e26\u4e0a\u5de5\u5355\u53f7\u548c\u73ed\u6b21\u5b57\u6bb5，\u800c\u4e0d\u662f\u53ea\u8bb0\u4e00\u4e2a\u603b\u6570\u3002
\nOEE \u662f\u8bca\u65ad\u6307\u6807，\u4e0d\u662f\u8003\u6838\u6307\u6807\u3002\u4e00\u65e6\u62ff\u6765\u8003\u6838，\u73b0\u573a\u5c31\u4f1a\u5f00\u59cb\u6311\u6570\u636e\u2014\u2014\u628a\u62a5\u8b66\u6539\u6210\u5f85\u673a\u3001\u628a\u4e0d\u826f\u54c1\u632a\u5230\u4e0b\u4e2a\u73ed\u6b21，\u6307\u6807\u597d\u770b\u4e86，\u95ee\u9898\u8fd8\u5728\u3002<\/p>\n","protected":false},"excerpt":{"rendered":" \u6458\u8981：\u300a\u4e0a\u6d77\u5e02\u52a0\u5feb\u53d1\u5c55\u65b0\u4e00\u4ee3\u667a\u80fd\u5236\u9020\u884c\u52a8\u65b9\u6848\u300b\u63d0\u51fa\u5230 2028 \u5e74\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7d2f\u8ba1\u8fbe 1600 \u5bb6，\u5e76\u628a\u201c\u5b9e\u73b0\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201d\u5199\u8fdb\u4e86\u57fa\u7840\u7ea7\u7684\u51c6\u5165\u8981\u6c42\u3002\u8fd9\u7bc7\u6587\u7ae0\u4ece\u5de5\u7a0b\u89d2\u5ea6\u62c6\u89e3\u4e09\u4ef6\u4e8b：\u6838\u5fc3\u6570\u636e\u5230\u5e95\u5206\u54ea\u4e09\u5c42\u3001\u8bbe\u5907\u6570\u636e\u4e3a\u4ec0\u4e48\u53ef\u4ee5\u4e0d\u5fc5\u5148\u8fc7 MES，\u4ee5\u53ca\u4e00\u6761\u4ece PLC \/ CNC \u5230\u65f6\u5e8f\u6570\u636e\u5e93\u7684\u6700\u5c0f\u53ef\u7528\u91c7\u96c6\u94fe\u8def（\u542b\u53ef\u8fd0\u884c\u7684 Python \u5b9e\u73b0\u4e0e\u4e09\u4e2a\u73b0\u573a\u5751）\u3002
\n\u672c\u6587\u76ee\u5f55
\n\u4e00\u3001\u5148\u7ed9\u7ed3\u8bba\u4e8c\u3001\u653f\u7b56\u539f\u6587\u91cc&<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[13546,1311,81,2606,188],"topic":[],"class_list":["post-119079","post","type-post","status-publish","format-standard","hentry","category-server","tag-13546","tag-opc-ua","tag-python","tag-2606","tag-188"],"yoast_head":"\n \u4e0a\u6d77\u201c54321\u201c\u667a\u80fd\u5236\u9020\u76ee\u6807\u4e0b\uff0c\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7684\u201c\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201c\u8981\u91c7\u4ec0\u4e48\u3001\u600e\u4e48\u91c7\uff08\u9644\u67b6\u6784\u4e0e Python \u5b9e\u73b0\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/119079.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u4e0a\u6d77\u201c54321\u201c\u667a\u80fd\u5236\u9020\u76ee\u6807\u4e0b\uff0c\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7684\u201c\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201c\u8981\u91c7\u4ec0\u4e48\u3001\u600e\u4e48\u91c7\uff08\u9644\u67b6\u6784\u4e0e Python \u5b9e\u73b0\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u6458\u8981：\u300a\u4e0a\u6d77\u5e02\u52a0\u5feb\u53d1\u5c55\u65b0\u4e00\u4ee3\u667a\u80fd\u5236\u9020\u884c\u52a8\u65b9\u6848\u300b\u63d0\u51fa\u5230 2028 \u5e74\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7d2f\u8ba1\u8fbe 1600 \u5bb6，\u5e76\u628a\u201c\u5b9e\u73b0\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201d\u5199\u8fdb\u4e86\u57fa\u7840\u7ea7\u7684\u51c6\u5165\u8981\u6c42\u3002\u8fd9\u7bc7\u6587\u7ae0\u4ece\u5de5\u7a0b\u89d2\u5ea6\u62c6\u89e3\u4e09\u4ef6\u4e8b：\u6838\u5fc3\u6570\u636e\u5230\u5e95\u5206\u54ea\u4e09\u5c42\u3001\u8bbe\u5907\u6570\u636e\u4e3a\u4ec0\u4e48\u53ef\u4ee5\u4e0d\u5fc5\u5148\u8fc7 MES，\u4ee5\u53ca\u4e00\u6761\u4ece PLC \/ CNC \u5230\u65f6\u5e8f\u6570\u636e\u5e93\u7684\u6700\u5c0f\u53ef\u7528\u91c7\u96c6\u94fe\u8def（\u542b\u53ef\u8fd0\u884c\u7684 Python \u5b9e\u73b0\u4e0e\u4e09\u4e2a\u73b0\u573a\u5751）\u3002 \u672c\u6587\u76ee\u5f55 \u4e00\u3001\u5148\u7ed9\u7ed3\u8bba\u4e8c\u3001\u653f\u7b56\u539f\u6587\u91cc&\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/119079.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-10-28T13:16:57+00:00\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"17 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/119079.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/119079.html\",\"name\":\"\u4e0a\u6d77\u201c54321\u201c\u667a\u80fd\u5236\u9020\u76ee\u6807\u4e0b\uff0c\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7684\u201c\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201c\u8981\u91c7\u4ec0\u4e48\u3001\u600e\u4e48\u91c7\uff08\u9644\u67b6\u6784\u4e0e Python \u5b9e\u73b0\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-10-28T13:16:57+00:00\",\"dateModified\":\"2026-10-28T13:16:57+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/119079.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/119079.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/119079.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u4e0a\u6d77\u201c54321\u201c\u667a\u80fd\u5236\u9020\u76ee\u6807\u4e0b\uff0c\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7684\u201c\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201c\u8981\u91c7\u4ec0\u4e48\u3001\u600e\u4e48\u91c7\uff08\u9644\u67b6\u6784\u4e0e Python \u5b9e\u73b0\uff09\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"\u4e0a\u6d77\u201c54321\u201c\u667a\u80fd\u5236\u9020\u76ee\u6807\u4e0b\uff0c\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7684\u201c\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201c\u8981\u91c7\u4ec0\u4e48\u3001\u600e\u4e48\u91c7\uff08\u9644\u67b6\u6784\u4e0e Python \u5b9e\u73b0\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/119079.html","og_locale":"zh_CN","og_type":"article","og_title":"\u4e0a\u6d77\u201c54321\u201c\u667a\u80fd\u5236\u9020\u76ee\u6807\u4e0b\uff0c\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7684\u201c\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201c\u8981\u91c7\u4ec0\u4e48\u3001\u600e\u4e48\u91c7\uff08\u9644\u67b6\u6784\u4e0e Python \u5b9e\u73b0\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u6458\u8981：\u300a\u4e0a\u6d77\u5e02\u52a0\u5feb\u53d1\u5c55\u65b0\u4e00\u4ee3\u667a\u80fd\u5236\u9020\u884c\u52a8\u65b9\u6848\u300b\u63d0\u51fa\u5230 2028 \u5e74\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7d2f\u8ba1\u8fbe 1600 \u5bb6，\u5e76\u628a\u201c\u5b9e\u73b0\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201d\u5199\u8fdb\u4e86\u57fa\u7840\u7ea7\u7684\u51c6\u5165\u8981\u6c42\u3002\u8fd9\u7bc7\u6587\u7ae0\u4ece\u5de5\u7a0b\u89d2\u5ea6\u62c6\u89e3\u4e09\u4ef6\u4e8b：\u6838\u5fc3\u6570\u636e\u5230\u5e95\u5206\u54ea\u4e09\u5c42\u3001\u8bbe\u5907\u6570\u636e\u4e3a\u4ec0\u4e48\u53ef\u4ee5\u4e0d\u5fc5\u5148\u8fc7 MES，\u4ee5\u53ca\u4e00\u6761\u4ece PLC \/ CNC \u5230\u65f6\u5e8f\u6570\u636e\u5e93\u7684\u6700\u5c0f\u53ef\u7528\u91c7\u96c6\u94fe\u8def（\u542b\u53ef\u8fd0\u884c\u7684 Python \u5b9e\u73b0\u4e0e\u4e09\u4e2a\u73b0\u573a\u5751）\u3002 \u672c\u6587\u76ee\u5f55 \u4e00\u3001\u5148\u7ed9\u7ed3\u8bba\u4e8c\u3001\u653f\u7b56\u539f\u6587\u91cc&","og_url":"https:\/\/www.wsisp.com\/helps\/119079.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-10-28T13:16:57+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"17 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/119079.html","url":"https:\/\/www.wsisp.com\/helps\/119079.html","name":"\u4e0a\u6d77\u201c54321\u201c\u667a\u80fd\u5236\u9020\u76ee\u6807\u4e0b\uff0c\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7684\u201c\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201c\u8981\u91c7\u4ec0\u4e48\u3001\u600e\u4e48\u91c7\uff08\u9644\u67b6\u6784\u4e0e Python \u5b9e\u73b0\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-10-28T13:16:57+00:00","dateModified":"2026-10-28T13:16:57+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/119079.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/119079.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/119079.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u4e0a\u6d77\u201c54321\u201c\u667a\u80fd\u5236\u9020\u76ee\u6807\u4e0b\uff0c\u57fa\u7840\u7ea7\u667a\u80fd\u5de5\u5382\u7684\u201c\u6838\u5fc3\u6570\u636e\u5b9e\u65f6\u91c7\u96c6\u201c\u8981\u91c7\u4ec0\u4e48\u3001\u600e\u4e48\u91c7\uff08\u9644\u67b6\u6784\u4e0e Python \u5b9e\u73b0\uff09"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/119079","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=119079"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/119079\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=119079"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=119079"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=119079"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=119079"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}} | |