Add s41_pipe_risk_probability

api/s41_pipe_risk_probability.py

@@ -0,0 +1,16 @@
+from .database import *
+from .s0_base import *
+
+def get_pipe_risk_probability_now(name: str, pipe_id: str) -> dict[str, float]:
+    t = try_read(name, f"select * from pipe_risk_probability where pipeid = '{pipe_id}'")
+    if t == None:
+        return {}
+
+    d = {}
+    d['pipeid'] = str(t['pipeid'])
+    d['pipeage'] = str(t['piepage'])
+    d['risk_probability_now'] = str(t['risk_probability_now'])
+
+    return d
+
+