Please enable JavaScript.

Coggle requires JavaScript to display documents.

My客群 (自動化執行 (標籤 (SQL -> ADW tables 對應 (更新頻率 (不定期 (disable_ind) (btmp…

- - - - 實際 table name
        
        聽 hippo-finish?
      - 更新頻率
        
        M
        
        D
      - tag_id == job_name
    - - 聽 kafka 訊息
        
        上游: hippo-finish
        
        hippo_name : batch_etl.tagging
    - - 客群執行頻率(submit-job)
        
        M
        
        D
  - - - 聽的 table 是一次性(不定期)更新的? 且 Job 已知一個月跑一次 #
        
        不定期 table +定期 table
        
        不聽不定期 table
        
        只有不定期 table
      - 在已 running 的狀態修改 ADW Table 字典 e.g. 頻率更正
        
        必須清除 persist 後重啟?
        
        記憶清除
    - - 實際 table name
        
        聽 frontier-adw
      - 更新頻率
        
        年(year_ind)
        
        月 (month_ind)
        
        日 (day_ind)
        
        代碼 (ref_ind)
        
        不定期 (disable_ind)
        
        btmp 為實質不定期
        
        bap_tag, bap_rec 為各自 service 掌握頻率
      - partition_id
      - partition_values(尚未 ready )
    - - 標籤執行頻率(submit-job)
        
        M
        
        D
    - - 聽 kafka 訊息
        
        上游: frontier-adw
- - - - 加入需求單號
        
        API
        
        history 需要接收 ticket parm
        
        current table 不變
        
        入庫程式
        
        需多打 ticket parm 給 API
        
        mongo schema
        
        history 要有 ticket parm
    - - CMS
      - MailHunter
      - 加入需求單號
    - - hash tag_id 尚未加入 timestamp
  - - - API
        
        current table 不變
        
        history 需要接收 ticket parm
      - 入庫程式
        
        需多打 ticket parm 給 API
      - mongo schema
        
        history 要有 ticket parm
- - - - 以字典檔和結果檔 join
        
        標籤
        
        依照頻率(M|D)決定，3號(T-2)開始每天列出本月份(天)應該要跑但還沒執行的標籤
        
        客群
        
        依照頻率(M|D)決定，3號(T-2)開始每天列出本月份(天)應該要跑但還沒執行的客群
      - 以 Kafka 訊息
        
        hippo-finish 的 is_success 為 false
        
        hippo-start 與 hippo-finish 成對