fix channel subs null value extraction, #803

2026-08-04 22:49:31 +00:00 · 2025-05-11 10:15:58 +07:00
parent c5f212f520
commit e34da1687e
3 changed files with 15 additions and 3 deletions
--- a/backend/channel/src/index.py
+++ b/backend/channel/src/index.py
@@ -157,8 +157,18 @@ class YoutubeChannel(YouTubeItem):
        # add ingest pipeline
        processors = []
        for field, value in self.json_data.items():
-            line = {"set": {"field": "channel." + field, "value": value}}
+            if value is None:
+                line = {
+                    "script": {
+                        "lang": "painless",
+                        "source": f"ctx['{field}'] = null;",
+                    }
+                }
+            else:
+                line = {"set": {"field": "channel." + field, "value": value}}
+
            processors.append(line)
+
        data = {"description": self.youtube_id, "processors": processors}
        ingest_path = f"_ingest/pipeline/{self.youtube_id}"
        _, _ = ElasticWrap(ingest_path).put(data)