संचालन और → प्रबंधन स्वचालित कार्यप्रवाह

स्वचालित वर्कफ़्लो

1) आपको इसकी आवश्यकता क्यों है

स्वचालित वर्कफ़्लो मैनुअल ऑपरेशन को कम करते हैं, "आइडिया-टू-मनी टाइम" को गति देते हैं और गलतियों के जोखिम को कम करते हैं। IGaming/fintech में, यह जमा/निकासी, KYC/AML, बोनस/जैकपॉट प्रबंधन, सामग्री अपडेट, घटना-प्रतिक्रियाओं और बैक-ऑफिस कार्यों के लिए महत्वपूर्ण है।

• ट्रिगर से परिणाम तक मजबूत, पारदर्शी रूप से देखी गई प्रक्रियाएं।
• प्रक्रिया एसएलओ द्वारा अनुमानित न्यूनतम मैनुअल कदम।
• त्रुटि नियंत्रण: रिट्रेज़, प्रतिपूरक क्रियाएं, स्पष्ट वृद्धि।
• घटनाओं द्वारा स्केलिंग और बिना तूफान और डुप्लिकेट के लोड।

2) बुनियादी शब्दावली

वर्कफ़्लो (WF): व्यावसायिक परिणाम प्राप्त करने के लिए कदमों (कार्यों) की एक श्रृंखला।

ऑर्केस्ट्रेशन: केंद्रीय समन्वयक चरणों और उनके आदेश का प्रबंधन करता है।

कोरियोग्राफी: घटनाओं पर प्रतिक्रिया देते हैं, कोई "केंद्रीय मस्तिष्क" नहीं है।

मुआवजा: आंशिक विफलता (सागा) में रिवर्स क्रियाएं।

HITL (ह्यूमन-इन-द-लूप): WF के भीतर "मैनुअल" समाधान नियंत्रित।

प्रक्रिया का एसएलओ: एक विशिष्ट डब्ल्यूएफ के पूरा होने/सफलता का लक्ष्य समय (उदाहरण के लिए, "95% जमा ≤ 3 सेकंड")।

3) कहां से लागू करें (उदाहरण)

भुगतान प्रवाह: जमा, धोखाधड़ी-विरोधी, लेखांकन में पोस्टिंग, सूचनाएं।

KYC/AML: दस्तावेजों का संग्रह, प्रदाताओं द्वारा जांच, अनुपालन में वृद्धि।

सामग्री/सीमा प्रबंधन: प्रकाशन खेल, कोटा, भू-नियम।

बोनस/जैकपॉट: अर्जन, कटौती, शर्तों की गणना, भुगतान।

घटनाएं: ऑटो-डायग्नोस्टिक्स, संक्षिप्त चेकलिस्ट, संचार।

डेटा/ईटीएल: रिपोर्ट अपलोड, सामंजस्य, संग्रह।

4) ऑर्केस्ट्रेशन बनाम कोरियोग्राफी

ऑर्केस्ट्रेशन उपयुक्त है जब: जटिल शाखा तर्क, सख्त एसएलओ, स्पष्ट समय सीमा/समय-सीमा, व्यवसाय द्वारा एक दृश्य "प्रक्रिया मानचित्र" की आवश्यकता होती है।

कोरियोग्राफी - जब: उच्च घटना, कमजोर कनेक्टिविटी, एक घटना के कई स्वतंत्र उपभोक्ता।

हाइब्रिड: लंबे समय तक रहने वाले सागा को एक ऑर्केस्ट्रेटर द्वारा नियंत्रित किया जाता है, और घटनाओं के माध्यम से स्थानीय प्रतिक्रि

5) वास्तुशिल्प सिद्धांत

पहचान: प्रत्येक चरण को सुरक्षित रूप से दोहराया जाना चाहिए (idempotency-key, संदेश-ID द्वारा dedup)।

स्पष्ट समय और पीछे हटना: बैकऑफ + जिटर, सीमाओं की कोशिश करें, केवल सुरक्षित गलतियों के लिए पीछे हटना।

मुआवजे (सागा): आंशिक विफलता पर चेन रोलबैक।

चरणों का अलगाव: बल्कहेड (बाहरी डाउनस्ट्रीम पर व्यक्तिगत पूल/सीमाएं)।

अनुबंध: सभी बाहरी कॉल के लिए OpenAPI/AsyncAPI, CDC परीक्षण।

WF वर्शनिंग: पुराने उदाहरणों के "द्रव्यमान" ड्रॉप के बिना इनपुट/आउटपुट डेटा के स्कीमा को बदलना।

6) घटना और ट्रिगर मॉडल

• डोमेन इवेंट ('जमा करें। निवेदित '),
• अनुसूची (क्रोन),
• मैनुअल स्टार्ट (ऑपरेटर/सपोर्ट),
• अलर्ट (घटना-ऑटो-वर्कफ़्लो) से संकेत।
• संदर्भ: सहसंबंध 'ट्रेस _ आईडी', 'वर्कफ़्लो _ इंस्टेंस _ आईडी', उपयोगकर्ता/क्षेत्र, फ़िचफ़्लाग संस्करण।
• सस्ते इनपुट फिल्टर: प्रारंभिक सत्यापन और कट-ऑफ लेता है।

7) चरण डिजाइन (कार्य)

प्रत्येक चरण का वर्णन किया गया है: प्रवेश, निकास, एसएलओ, समय समाप्ति, प्रयास, रिट्रे शर्तें, मुआवजा, अधिकार/रहस्य।

task: call_psp input: { user_id, amount, currency, idempotency_key }
timeout: 200ms retries:
max: 2 on: [5xx, connect_error]
backoff: exponential jitter: true compensation: reverse_authorization secrets: [PSP_TOKEN]
sla: p99 <= 300ms

8) मुआवजा और सागा

स्थानीय लेनदेन + घटना "इरादे को सहेजें → प्रकाशित घटना।"

मुआवजा: प्राधिकरण रद्द करना, बोनस की वापसी, संतुलन पुनर्गणना, टिकट बंद करना।

मुआवजा पहचान: बार-बार रद्द किए जाने से आक्रमणकारियों को नहीं तोड़ ना चाहिए।

9) सुरक्षा और रहस्य

केएमएस/गोपनीयता प्रबंधक: टोकन भंडारण, घुमाव, भूमिका पहुँच.

कम से कम विशेषाधिकार: WF इंजन बिल्कुल सही स्कोप दिया गया है।

वेबहुक/कोलबेक हस्ताक्षर: HMAC/JWS, टाइमस्टैम्प जांच।

डेटा नीतियाँ: लॉग/निशान, एन्क्रिप्शन में पीआईआई मास्किंग।

10) अवलोकन और एसएलओ

प्रक्रिया मेट्रिक्स: 'वर्कफ़्लो _ स्टार्ट/पूरा', 'सक्सेस _ रेट', 'गर्भपात', 'मीन/p95/p99 अवधि', हैंगिंग इंस्टेंस, 'डेड लेटर'।

स्टेप मेट्रिक्स: 'टास्क _ लेटेंसी', 'एरर _ रेट', 'रेट्री _ काउंट', 'ओपन _ सर्किट', 'कॉस्ट _ per _ 1k _ कॉल'।

ट्रेस: प्रत्येक चरण के लिए स्पैन, टैग 'वर्कफ़्लो। नाम ',' चरण ',' प्रयास '।

SLO: उदाहरण के लिए, "95% जमा ≤ 3 सेकंड, 99% ≤ 5 सेकंड; गर्भपात ≤ 0। 3 %/दिन"।

डैशबोर्ड: थर्मल स्टेप मैप, अड़ चनें, निर्भरता के नक्शे।

11) मानव-इन-सर्किट (HITL)

मानदंड: विवादास्पद मामले (जोखिम/एएमएल), बड़े भुगतान की मैनुअल पुष्टि।

डेडलाइन: निर्णय की प्रतीक्षा में टाइमआउट, रिमाइंडर/एस्केलेशन।

ऑडिट: कौन/कब/क्या तय किया, औचित्य, टिकट के साथ बंडल।

12) परिवर्तन प्रबंधन और रिलीज़

वर्कफ़्लो संस्करण: समानांतर में 'v1' और 'v2'; उदाहरण प्रवासन संभव नहीं है - पुराने उदाहरणों को स्वाभाविक रूप से समाप्त करें, 'v2' के लिए नया याता

कैनरी ट्रैफ़िक: 1% → 10% → 100%, मेट्रिक्स 'सफलता/p95/गर्भपात' की तुलना।

Ficheflags: पिछले चरण/शाखा कार्यान्वयन के लिए एक त्वरित रोलबैक।

सीडीसी/अनुबंध: उपभोक्ताओं/प्रदाताओं को तोड़ ने से कदम रखने के लिए सीआई में गेट।

13) परीक्षण

इकाई चरण: सकारात्मक/नकारात्मक + पहचान।

संविदा परीक्षण: मोका/चरण प्रदाता के खिलाफ।

डब्ल्यूएफ सिमुलेशन: हैप्पी-पाथ + टाइमआउट, 4xx/5xx, "स्लो प्रदाता", घटनाओं का नुकसान, आंशिक त्रुटियां।

खेल-दिन: ग्लिच का इंजेक्शन (PSP/KYC ड्रॉप, कतार लैग, बंद ब्रेकर)।

रीप्ले: माइग्रेशन को मान्य करने के लिए ऐतिहासिक घटनाओं को दोहराएं।

14) घटनाएं और ऑटो-प्रतिक्रियाएं

हादसा ऑटो-वर्कफ़्लो: मैट्रिक्स एकत्र करना, डाउनस्ट्रीम की जाँच करना, सूचनाएँ, वर्कअराउंड तैयार करना (स्विचिंग प्रदाता, गिरावट)।

रनबुक चरण: मैनुअल गर्भपात/बल-पूर्ण होने पर "अनटैंगल" कैसे लटका दिया जाता है।

15) लागत प्रबंधन

कोटा और "सॉफ्ट-कैप": महंगे चरणों/प्रदाताओं पर सीमा।

कैश/डीडअप: बार-बार बाहरी कॉल अनावश्यक रूप से न करें।

रिपोर्ट: WF प्रकार द्वारा 'cost _ per _ 1k _ workflows', "सफलता की लागत"।

16) मिनी-टेम्पलेट वर्कफ़्लो (छद्म-YAML)

workflow: deposit_v1 trigger:
event: deposit.requested filters: [amount > 0, currency in [USD,EUR,TRY]]
sla:
p95_ms: 3000 abort_rate_daily: 0.3%
steps:
- name: reserve_funds timeout_ms: 150 retries: {max: 2, on: [5xx, connect_error], backoff: exponential, jitter: true}
compensation: release_reserve
- name: call_psp timeout_ms: 200 retries: {max: 2, on: [5xx, connect_error]}
circuit_breaker: {error_rate: 0.05, window_s: 10, open_s: 30}
- name: post_ledger type: async topic: ledger.post
- name: notify_user channel: push hitl:
when: amount > 10000 or risk_score > 0.8 timeout_m: 30 escalate_to: "compliance@oncall"
observability:
emit_metrics: true trace: true security:
secrets: [PSP_TOKEN, PUSH_API_KEY]

17) रिट्रे और टाइमआउट नीतियां (सिफारिशें)

स्टेप टाइमआउट = इसके विलंबता बजट का 70-80%।

Retrai ≤ 2-3, केवल अज्ञात संचालन और नेटवर्क विफलताओं के लिए।

जिटर अनिवार्य है; फॉलबेक के बिना अड़ चन टाइमआउट से प्रतिबंध पीछे हटता है।

मुआवजा - अलग चरणों के रूप में, पहचान भी।

18) डैशबोर्ड (न्यूनतम)

WF अवलोकन: लॉन्च/सफलता/गर्भपात, p95/p99 अवधि, हैंग/दादा।

स्टेप ड्रिलडाउन: शीर्ष धीमी/गलती के कदम, पीछे हटना, खुले ब्रेकर।

प्रदाता फलक: आउटगोइंग p95/त्रुटि-दर/कोटा/लागत.

HITL बोर्ड: "लंबित निर्णय", समयरेखा, अनुपालन SLA।

19) कार्यान्वयन चेकलिस्ट

• कुंजी डब्ल्यूएफ मानचित्र और मालिक (ऑन-कॉल, चैट, रेपो)।
• चरणों का विवरण: इन/आउट, एसएलओ, टाइमआउट, रिट्रे, क्षतिपूर्ति, रहस्य।
• OpenAPI/AsyncAPI + CDC अनुबंध।
• प्रवेश द्वार पर और चरणों में आइडेम्पोटेंस/डेडअप।
• डैशबोर्ड, निशान, अलर्ट (एसएलओ प्रक्रिया और कदम)।
• WF रिलीज़ के लिए कैनरी + phicheflags।
• रनबुक: कैसे "ट्रीट" किया जाए/आंशिक रूप से डब्ल्यूएफ को निष्पादित किया जाए।
• गिरावट योजना: वैकल्पिक प्रदाता, "भारी" शाखाओं को बंद करना।
• गुप्त/पहुंच/लेखा परीक्षा नीतियां।
• खेल-दिन/xaoc-परिदृश्य एक बार एक स्प्रिंट।

20) अलर्ट के उदाहरण (विचार)

ALERT WorkflowSLOBreached
IF workflow_p95_duration_ms{name="deposit_v1"} > 3000 FOR 15m
LABELS {severity="critical", team="payments"}

ALERT WorkflowAbortRateHigh
IF rate(workflow_aborted_total{name="deposit_v1"}[30m]) > 0.005
LABELS {severity="warning", team="payments"}

ALERT StepRetryStorm
IF step_retry_count{name="call_psp"} > 2 baseline_1w FOR 10m
LABELS {severity="warning", team="integrations"}

ALERT StuckInstances
IF workflow_in_progress_age_p95_m{name="kyc_v2"} > 60
LABELS {severity="warning", team="risk"}

21) एंटी-पैटर्न

100 + चरणों और कठोर कनेक्टिविटी के साथ "बड़ेअखंड डब्ल्यूएफ" - कठिन और शोर को तोड़ ता है।

गैर-आइडेम्पोटेंट लेनदेन (डबल चार्ज/चार्ज) के लिए रिट्रेज़।

उपयोगकर्ता के अनुरोध - जल्लाद और "लाश" के समय "जीवन से अधिक लंबा"।

मुआवजे की कमी - मैनुअल फिक्स और लंबे पोस्टमार्टम।

कोई डब्ल्यूएफ वर्शनिंग - रिलीज पुराने उदाहरणों को तोड़ ता है।

रोटेशन और ऑडिट के बिना कॉन्फ़िग/चर के अंदर का राज़.

22) वर्कफ़्लो क्वालिटी केपीआई

WF प्रकार द्वारा सफलता दर और गर्भपात दर।

p95/p99 चरणों और प्रक्रिया की अवधि।

प्रक्रिया की घटनाओं पर MTTD/MTTR।

पुन: तूफान की गिनती/महीना (लक्ष्य → 0)।

प्रति 1k WF लागत और "सफलता की लागत"।

स्वचालन का हिस्सा: HITL के बिना मामलों का%।

23) तेज शुरुआत (डिफ़ॉल्ट)

3-5 महत्वपूर्ण डब्ल्यूएफ (जमा, निकासी, केवाईसी) के साथ शुरू करें।

ऑर्केस्ट्रेट लंबे समय तक रहने वाले सागा; स्थानीय प्रतिक्रियाएँ - घटनाएँ।

बजट का स्टेप टाइमआउट ≤ 80%; बैकऑफ + जिटर के साथ रेट्राई ≤ 2।

क्षतिपूर्ति लिखित और परीक्षण में निर्धारित

तुलना डैशबोर्ड के साथ 5-10% यातायात के लिए कैनरी चालू करें।

प्रत्येक WF में एक मालिक, एक रनबुक और SLO अलर्ट होता है।

24) एफएक्यू

प्रश्न: क्या चुनना है: ऑर्केस्ट्रेटर या घटनाएं?

A: यदि आपको एक दृश्य मानचित्र की आवश्यकता है, तो समय सीमा और लंबी सागा एक ऑर्केस्ट्रेटर हैं। यदि घटनाओं और बहुत सारे उपभोक्ताओं के लिए सरल प्रतिक्रियाएं प्रबल होती हैं, तो कोरियोग्राफी। अक्सर सबसे अच्छा विकल्प एक संकर होता है।

प्रश्न: आप डुप्लिकेट से कैसे बचें?

A: WF इनपुट पर Idempotency-key, 'mession _ id' द्वारा dedup और "देखा-घटनाओं का भंडारण। "कदम आदर्श हैं।

प्रश्न: क्या इसे मैन-इन-द-सर्किट की आवश्यकता है?

A: हाँ, विवादास्पद/महंगे मामलों के लिए। लेकिन बेहतर स्वचालन और नियमों के माध्यम से HITL शेयर को मापना और कम करना।