Maniġer tal-Fluss tax-Xogħol Crosswork tas-CISCO

Installa CWM bl-użu tal-Għodda tal-Installazzjoni Docker
Din it-taqsima fiha s-suġġetti li ġejjin:
Installa CWM bl-użu ta' Docker Installer Tool, f'paġna 1
Installa CWM bl-użu tal-Għodda tal-Installazzjoni Docker
Is-CWM 2.0 huwa installat fuq il-pjattaforma Cisco Crosswork billi l-ewwel jiġi skjerat il-Crosswork OVA file bl-użu ta' immaġni Docker fuq il-VMware vCenter 7.0 (jew ogħla) u mbagħad l-installazzjoni tas-CWM CAPP file bl-użu tal-iskritt tal-installazzjoni.
Prerekwiżiti
- VMware vCenter Server 7.0 (U3p jew aktar tard) u ESXi 7.0 (U3p jew aktar tard). Irreferi għar-rekwiżiti tal-installazzjoni ta' Crosswork Network Controller 7.0 għal aktar dettalji.
- Verżjoni 19 ta' Docker jew ogħla.
- sshpass installat. Għal Mac, tista' tuża brew install sshpass.
Uża skript biex Tiskjera Crosswork u CWM
Proċedura
- Pass 1 Fil-magna tiegħek li taħdem b'Docker, oħloq direttorju fejn se taħżen id-dejta kollha files li se tuża matul din l-installazzjoni.
Nota
Jekk qed tuża Mac, kun żgur li l-isem tad-direttorju huwa b'ittri żgħar. - Pass 2 Niżżel l-OVA file li fih il-pakkett Crosswork Network Controller minn cisco.com għad-direttorju li ħloqt. Dan se jkun fih il-Crosswork tar.gz CAPP file, is-CWM .ova file, l-iskritt tal-installazzjoni install.sh, il-configuration.json file u l-immaġni tal-installatur ta' Docker tar.gz (flimkien ma' din l-istruzzjoni).
- Pass 3 Importa l-immaġni tal-installatur ta' Docker billi tħaddem il-kmand li ġej. Kun żgur li taġġusta l-isem tal-immaġni kif meħtieġ: docker image import .tar.gz isem-l-immaġni-tiegħek:tiegħek-tag
- Pass 4 Fid-direttorju, oħloq .txt file u waħħal il-mudell tal-installazzjoni tal-VMware mogħti hawn taħt. Għal din l-istruzzjoni, se nsemmu l- file deployment.tfvars.txt pereżempjuampskopijiet le.
Cw_VM_Image = “” # Linja miżjuda awtomatikament mill-installatur.- Munzell tal-ClusterIPStack = “IPv4”
- Maskra tan-NetworkIP tad-Data = “255.255.255.0”
- DataIPGateway = “192.168.1.1”
- DNS = “DNS”
- IsemDominju = “isem_dominju”
- CWPassword = “il-password_tal-crosswork_tiegħek”
- Daqs tal-VM = “KBIR”
- daqsijiet_tal-vm = {
- "xkbir" = {
- vcpus = 24
- riservazzjoni_tas-CPU = 24000
- //Memorja f'Mbytes
- memorja = 128000
- }
- }
- NTP = “ntp.esl.cisco.com
- Żona tal-Ħin = “Ewropa/Pariġi”
- EnableSkipAutoInstallFeature = “Veru”
- ManagementVIP = “your_mgmt_vip”
- ManagementIPNetmask = “255.255.255.0”
- ManagementIPGateway = “il-gateway_tal-ġestjoni_tiegħek”
- ThinProvisioned = “veru”
- DataVIP = “id-data_vip_tiegħek”
- CwVMs = {
- “0” = {
- Isem_VM = “isem_VM_tiegħek”,
- Indirizz IP tal-Ġestjoni = “l-IP_tal-ġestjoni tiegħek”,
- Indirizz_IP tad-Data = “l-indirizz_ip_tad-data_tiegħek”,
- Tip ta' Nodu = “Ibridu”
- }}
- VCenterDC = {
- Indirizz_tal-VCenter = “l-indirizz_tal-vcenter_tiegħek”,
- VCenterUser = “l-isem_tal-utent tiegħek”,
- VCenterPassword = “il-password_tiegħek”,
- Isem tad-DC = “isem_taċ-ċentru_tad-dejta_tiegħek”,
- IsemNetwerk tal-Ġestjoni = “Netwerk tal-VM”,
- Isem tan-Netwerk tad-Data = “Netwerk tad-Data tal-SVM”
- VMs = [{
- HostedCwVMs = [“0”],
- Host = “il-host_tal-VM_tiegħek”,
- Datastore = “il-maħżen_tad-dejta_tal-VM_tiegħek”,
- HSDatastore = “il-maħżen_tal-hsdatastore_tal-VM_tiegħek”
- }
]} - Verżjoni tal-Iskema = “7.1.0”
- Nota
- Innota d-differenza bejn il-VCenter u d-Datacenter tiegħek.
- Pass 5 Editja l-parametri biex jaqblu mal-iskjerament tiegħek.
Nota
Biex titgħallem aktar dwar il-parametri tal-installazzjoni, jekk jogħġbok irreferi għall-kapitlu dwar VM Unika fin-Netwerk Cisco Crosswork.
Gwida għall-Installazzjoni tal-Kontrollur 7.0. - Pass 6 Fid-direttorju, oħloq ieħor file prodott imsemmi.json file u waħħal id-dejta hawn taħt.
- {
- "id_tal-prodott": "CWM",
- "attribut": {
- “ċavetta1”: “valur1”,
- “ċavetta2”: “valur2”
- }}
- Pass 7 Iftaħ il-configuration.json file u ipprovdi l-parametri li ġejjin biex jaqblu mal-iskjerament tiegħek:
- {
- “ISEM_SVM”: “isem_VM_tiegħek”,
- "ospitanti": {
- "remote_user": "l-isem tal-utent tiegħek",
- “remote_password”: “il-password_tiegħek”,
- "remote_host": "your_scp_host",
- "port_remot": "22",
- "kapp_"file": "/mogħdija/għal/capp_file".tar.gz"
- },
- "cwm_login": {
- "ip": "l-ip_tal-ġestjoni_tiegħek",
- "cwm_user": "admin",
- "cwm_old_password": "admin",
- “cwm_password”: “il-password_ġdida_tiegħek”
- },
- "skjerament": {
- “tfvars_path”: “/path/to/deployment.tfvars.txt”,
- "bajda_"file”: “/mogħdija/lejn/cwm.ova”,
- “product_json”: “/mogħdija/lejn/prodott.json”
- }
- }
- Għall-host, ipprovdi d-dettalji tas-server SCP fejn jinsab il-Crosswork CAPP tiegħek. file jinsab bħall-indirizz u l-port tal-host, l-isem tal-utent u l-password tiegħek, u t-triq lejn file.
- Għal cwm_login, ipprovdi l-IP tal-maniġment tiegħek u l-username u l-password default ta' Crosswork. F'cwm_password, ipprovdi l-password il-ġdida biex tissostitwixxi dik default malli titlesta l-installazzjoni.
- għall-iskjerament, ipprovdi l-mogħdijiet lokali għad-deployment.tfvars.txt maħluq f'pass preċedenti, għas-CWM OVA file u għall-product.json file.
- Pass 8 Mid-direttorju, mexxi l-iskritt tal-installatur: bash install.sh
Dan se jibda l-proċess ta' installazzjoni għall-pjattaforma Crosswork u mbagħad għal CWM ladarba l-pjattaforma tkun skjerata. - Pass 9 Biex issegwi l-installazzjoni ġewwa l-kontenitur Docker, mexxi l-kmand li ġej: sudo docker ps -a
Ikkopja l-ID tal-kontenitur li fih bdiet l-installazzjoni. Normalment ismu jkun fih l-OVA fileisem, bħal: cw-na-cwm-7.1.0-20-releasecnc710-250512-cwm-59-50
Biex tara l-logs, mexxi: sudo docker logs your_container_id -f - Pass 10 Ladarba l-iskritt tal-installazzjoni jkun lest u l-istatus tad-displej jilħaq il-100%, mur fuq http://your_mgmt_vip_address:30603 u idħol bl-utent admin awtomatiku u l-password li pprovdejt f'configuration.json.
Sistema
Din it-taqsima tkopri s-suġġetti li ġejjin:
Arkitettura spiċċatview, f’paġna 5
Arkitettura spiċċatview
L-arkitettura ta' Cisco Crosswork Workflow Manager 2.0 hija soluzzjoni bbażata fuq mikroservizzi li topera fuq il-pjattaforma CNC. Din it-taqsima turi dijagramma li tippreżenta l-komponenti arkitettoniċi ewlenin tagħha flimkien ma' deskrizzjonijiet qosra ta' kull wieħed.
Server tal-UI: Jippermetti lill-operaturi jżidu u joħolqu istanzji tal-flussi tax-xogħol, idaħħlu dejta tal-fluss tax-xogħol, jelenkaw il-flussi tax-xogħol li jkunu qed jaħdmu, jimmonitorjaw il-progress tax-xogħol. It-taqsima tal-Amministrazzjoni tal-UI tas-CNC tippermetti lill-utenti jżidu ħaddiema, jimmaniġġjaw il-proċessi tal-ħaddiema u jassenjaw attivitajiet minn adapters għal ħaddiema.- REST API: Tinkludi l-interazzjoni kollha mal-applikazzjoni CWM: l-iskjerament tal-adapters, il-pubblikazzjoni u l-instanzjazzjoni tal-flussi tax-xogħol, il-ġestjoni tal-ħaddiema, ir-riżorsi u s-sigrieti.
- Server tal-API: Jibgħat talbiet tal-API lil mikroservizzi rilevanti.
- Magna: Il-komponent ewlieni li jmexxi kif jiġu mmaniġġjati l-flussi tax-xogħol. Jinterpreta u jimmaniġġja l-eżekuzzjoni tad-definizzjonijiet tal-flussi tax-xogħol.
- Ħaddiem tal-Magna (Ħaddiem tal-Fluss tax-Xogħol): Jeżegwixxi l-kompiti tal-fluss tax-xogħol. Jirċievi l-kompiti tal-fluss tax-xogħol mill-Magna, jeżegwixxihom fl-ordni korretta, u jibgħat ir-riżultati lura lill-Magna.
- Maniġer tal-Ħaddiema: Jimmaniġġja l-Ħaddiema tal-Fluss tax-Xogħol. Jiżgura li n-numru korrett ta' ħaddiema jkunu qed jaħdmu u li jkunu kkonfigurati kif suppost.
- Maniġer tal-Adapter: Jimmaniġġja l-adapters użati mis-sistema. Jinstalla, jikkonfigura, u jaġġorna l-adapters (“plugins”) u jiżgura li huma kompatibbli mas-sistema.
- Maniġer tal-Avvenimenti: Jimmaniġġja l-avvenimenti li deħlin u ħerġin, u jibgħathom lill-kjuwijiet tal-avvenimenti korretti. L-avvenimenti huma sinjali li ġejjin minn sorsi esterni li magħhom jistgħu jinteraġixxu l-flussi tax-xogħol.
- Adapter SDK & XDK: Jgħin lill-iżviluppaturi joħolqu adapters ġodda biex jintegraw ma' sistemi esterni. L-applikazzjoni XDK testendi l-kapaċitajiet tal-Adapter SDK biex tippermetti lill-iżviluppaturi jibnu awtomatikament interfaċċji u loġika tal-messaġġi għal adapters apposta.
- Definizzjonijiet tal-Workflow: Kodiċi tal-workflow miktub fil-format JSON ibbażat fuq l-ispeċifikazzjoni tas-Serverless Workflow.
- Kontrollur tan-Netwerk Crosswork (CNC): Pjattaforma ta' runtime għall-applikazzjoni CWM. Hija ġabra ta' servizzi li jipprovdu l-infrastruttura meħtieġa biex jappoġġjaw l-iskjerament u l-ġestjoni tal-applikazzjoni fi ħdan skjerament ta' Cluster.
- PostgreSQL: Id-database li s-sistema tuża biex taħżen u timmaniġġja d-dejta tagħha.
- Magna DSL: Teżegwixxi l-Lingwa Speċifiku għad-Dominju (DSL) użata biex tiddefinixxi l-flussi tax-xogħol. Tanalizza d-DSL, tiġġenera l-kodiċi xieraq tal-fluss tax-xogħol, u tikkumpilah għall-eżekuzzjoni.
- Tqabbil tal-Magna: Tqabbel l-avvenimenti li deħlin mal-fluss tax-xogħol xieraq. Din tiddetermina liema fluss tax-xogħol għandu jiġi eżegwit abbażi tad-dejta tal-avveniment u r-restrizzjonijiet definiti tal-fluss tax-xogħol.
- Storja tal-Magna Tirreġistra l-istorja tal-flussi tax-xogħol eżegwiti. Taħżen il-metadata u d-dettalji tal-eżekuzzjoni tal-flussi tax-xogħol kollha li tlestew, li għaddejjin u li fallew.
API
Din it-taqsima tkopri s-suġġetti li ġejjin:
API tas-CWM Fuqview, f’paġna 7
Uża l-kollezzjoni Postman tal-Awtomazzjoni tal-Fluss tax-Xogħol CNC, f'paġna 7
API tas-CWM Fuqview
Cisco żviluppa l-API tas-Cisco Crosswork Workflow Manager ibbażata fuq il-prinċipji tad-disinn tar-Rappreżentational State Transfer (REST). Tista' taċċessa l-API billi tuża HTTP u dejta. fileifformattjat bl-użu ta' JSON. L-API tindika s-suċċess jew il-falliment ta' talba partikolari bl-użu ta' kodiċijiet ta' rispons HTTP rilevanti. Il-metodi ta' rkupru tad-dejta jeħtieġu talba GET, filwaqt li l-metodi għaż-żieda, il-bdil, jew it-tħassir tad-dejta jeħtieġu metodi POST, PUT, PATCH, jew DELETE, kif xieraq. L-API tirritorna żbalji jekk tibgħat talbiet bl-użu tat-tip ta' talba żbaljat.
Tista' tuża s-CWM API billi tuża kollezzjoni CWM 2.0 Postman f'Postman.
Għal referenza sħiħa tal-API, ara l-ispazju ddedikat tad-DevNet: https://devnetapps.cisco.com/docs/crosswork/workflow-manager/introduction/
Uża l-kollezzjoni Postman tal-Awtomazzjoni tal-Fluss tax-Xogħol CNC
Segwi dawn il-passi biex timporta l-kollezzjoni fl-applikazzjoni Postman u tissettja l-ambjent tal-iżvilupp.
Qabel ma tibda
Kun żgur li għandek aċċess għal Postman web kont tal-applikazzjoni jew installajt l-app tad-desktop Postman. Għal aktar dettalji, ara https://www.postman.com/downloads/
Trid tniżżel ukoll il-kollezzjoni CNC Workflow Automation Postman fil-format JSON billi tikklikkja fuq din il-link u mbagħad tneħħi l-arkivju għal riżorsa ta' ħażna aċċessibbli.
Proċedura
- Pass 1 Iftaħ Postman u mur fil-Kollezzjonijiet.
- Pass 2 Ikklikkja Importa, agħżel folders mill-iskrin Drop anywhere to import, u pponta lejn il-folder li żzippjajt mill-arkivju tal-kollezzjoni CNC Workflow Automation Postman.
- Pass 3 Mur f'Ambjenti u agħżel l-ambjent tat-test li għadek kif importajt.
- Pass 4 Ipprovdi l-valuri attwali għall-bażiUrl u l-varjabbli endPoint biex jaqblu mal-indirizz IP u l-port tal-istanza tal-Awtomazzjoni tal-Fluss tax-Xogħol CNC tiegħek. Issejvja ssalva l-bidliet.
Biex tikseb aċċess għall-API tal-Awtomazzjoni tal-Fluss tax-Xogħol CNC, uża l-bażiurl/crosswork/cnc/v71/, fejn il-bażiurl huwa l-indirizz IP u n-numru tal-port tal-istanza tiegħek ta' Crosswork Network Controller (CNC) b'CNC Workflow Automation installata. Pereżempjuample: https://172.22.141.178:30603
Avvenimenti
Din it-taqsima tkopri s-suġġetti li ġejjin:
Immaniġġjar tal-avvenimenti lestview, f’paġna 9
Iddefinixxi avveniment ta' Kafka, f'paġna 16
Immaniġġjar tal-avvenimenti lestview
Il-mekkaniżmu tal-immaniġġjar tal-avvenimenti jippermetti lis-CWM jinteraġixxi ma' sensara esterni għall-immaniġġjar ta' avvenimenti deħlin u ħerġin. Il-flussi tax-xogħol jistgħu jaġixxu jew bħala konsumaturi jew produtturi ta' avvenimenti li jistgħu jintużaw biex jibdew fluss tax-xogħol ġdid, jew jagħtu sinjal ta' fluss tax-xogħol eżistenti. Għal kull tip ta' avveniment li tiddefinixxi, tista' żżid attributi ta' korrelazzjoni għall-iffiltrar tal-avvenimenti u r-rotta tagħhom lejn il-fluss tax-xogħol li jistenna l-avveniment li fih valuri ta' attributi speċifiċi.
Il-messaġġi tal-avvenimenti jeħtieġ li jiġu definiti skont l-ispeċifikazzjoni tal-Cloud Events. Ara l-format tal-messaġġ tal-avveniment, f'paġna 15 għal aktar dettalji.
Sensara u protokolli
CWM jappoġġja l-broker Kafka u l-protokolli AMQP u HTTP għall-immaniġġjar tal-avvenimenti. L-avvenimenti jistgħu jew jiġu kkunsmati minn fluss tax-xogħol li jaħdem ġewwa CWM (avvenimenti deħlin mibgħuta minn broker) jew prodotti minn fluss tax-xogħol li jaħdem u mibgħuta lil sistema esterna (avvenimenti ħerġin riċevuti minn broker).
Huwa importanti li wieħed jiftakar li s-CWM ma jaġixxix bħala sensar tal-avvenimenti fih innifsu. Jipprovdi mezz biex tikkonnettja ma' sensara esterni biex tibgħat messaġġi u avvenimenti.
Sensar ta' Kafka
Għat-tip ta' avveniment ta' konsum, CWM jikkonnettja ma' broker Kafka u jisma' tip ta' avveniment speċifiku fuq suġġett. Ladarba avveniment tat-tip speċifiku jirreġistra mas-suġġett it-tajjeb, CWM jirkupra d-dejta tal-avveniment u jibgħatha lill-fluss tax-xogħol li jkun qed jaħdem. Il-fluss tax-xogħol imbagħad jesegwixxi azzjonijiet definiti fl-Istat tal-Avveniment u/jew imexxi eżekuzzjoni oħra ta' fluss tax-xogħol (jekk magħżul).
Għat-tip ta' avveniment "produce", fluss tax-xogħol li jkun qed jaħdem jipproduċi avveniment wieħed jew sett ta' avvenimenti li CWM imbagħad jibgħat lis-sensar u jiġu ppubblikati fit-tema t-tajba.
Il-broker Kafka jaċċetta kull format ta' messaġġ ta' avveniment appoġġjat mill-SDK speċifiku għal-lingwa sakemm jintbagħat tip ta' kontenut validu. Ara din il-link ta' Github għal-listi ta' formati appoġġjati: https://github.com/cloudevents/spec?tab=readme-ov-file
Protokoll AMQP (bħall-broker RabbitMQ)
Għat-tip ta' avveniment ta' konsum, CWM jikkonnettja ma' sensar AMQP u jisma' tip ta' avveniment speċifiku fuq kju. B'mod simili għall-sensar Kafka, meta avveniment tat-tip speċifiku jirreġistra fil-kju t-tajjeb, CWM jirkupra d-dejta tal-avveniment u jibgħatha lill-fluss tax-xogħol li jkun qed jaħdem. Il-fluss tax-xogħol imbagħad jesegwixxi azzjonijiet definiti fl-Istat tal-Avveniment u/jew imexxi eżekuzzjoni oħra ta' fluss tax-xogħol (jekk magħżul).
Għat-tip ta' avveniment "produce", fluss tax-xogħol li jkun qed jaħdem jipproduċi avveniment wieħed jew sett ta' avvenimenti li CWM imbagħad jibgħat lis-sensar u jiġu ppubblikati fil-kju t-tajjeb.
Is-sensara tal-AMQP jaċċettaw kull format ta' messaġġ ta' avveniment appoġġjat mill-SDK speċifiku sakemm jintbagħat tip ta' kontenut validu. Il-listi tal-formati ta' avvenimenti appoġġjati huma disponibbli hawn: https://github.com/cloudevents/spec?tab=readme-ov-file
Protokoll HTTP
Għat-tip ta' avveniment konsum, CWM jesponi endpoint HTTP li jisma' kwalunkwe avveniment li jkun dieħel. Jekk jasal avveniment ta' tip speċifiku, dan jintbagħat lill-fluss tax-xogħol li jkun qed jaħdem u li jistenna dan it-tip ta' avveniment.
Meta jiġu kkunsmati avvenimenti, CWM jiffunzjona bħala s-server HTTP tad-destinazzjoni. Għalhekk, il- URL tas-server tas-CWM huwa dak li inti tipprovdi b'mod effettiv bħala r-riżorsa għat-tip ta' avveniment HTTP mogħti.
- Il-messaġġi tal-avvenimenti jeħtieġ li jkunu talbiet HTTP POST, u l-korp tal-messaġġ jeħtieġ li jkun fil-format JSON li jirrappreżenta Avveniment tal-Cloud:
- { "ispetverżjoni": "1.0",
- “id”: “2763482-4-324-32-4”,
- "tip": "com.github.pull_request.opened",
- "sors": "/sensors/tn-1234567/alerts",
- "tip ta' kontenut tad-dejta": "test/xml",
- "dejta": " ","
- “IsemAttrKuntest”: “ValurAttrKuntest” }
- Għal avvenimenti ta' produzzjoni, fluss tax-xogħol jipproduċi avveniment fil-format tal-Avveniment tal-Cloud u CWM jibgħatu bħala
- Talba HTTP POST lil endpoint HTTP espost minn sistema esterna. L-indirizz tal-endpoint HTTP huwa konkatenazzjoni tal-host URL definit fil-konfigurazzjoni tar-Riżorsa fis-CWM u l-qasam tal-Punt tat-tmiem tal-
- Definizzjoni tal-avveniment fid-definizzjoni tal-fluss tax-xogħol. Fil-konfigurazzjoni tar-riżorsa, tista' tbiddel il-metodu tat-talba għal PUT jew ieħor, u żżid pari ta' ċwievet u valuri bħala header (fil-format JSON):

Konfigurazzjoni tas-sistema tal-avvenimenti
Is-suġġetti li ġejjin ikopru d-dettalji tal-konfigurazzjoni tal-avvenimenti.
Konfigurazzjoni tas-sistema tal-avvenimenti: sigrieti
Fil-konfigurazzjoni tal-avvenimenti, is-sigrieti jaħżnu l-kredenzjali meħtieġa biex jippermettu konnessjoni ma' broker jew endpoint espost minn servizz ta' parti terza li jibgħat jew jirċievi avvenimenti. Dan jinkludi awtentikazzjoni bażika: isem l-utent u password. L-ID tas-Sigriet li tipprovdi meta toħloq sigriet se jiġi referenzjat meta toħloq riżorsa, għalhekk trid iżżid sigriet minn qabel. Għal aktar dettalji, ara Pass 1: Oħloq sigriet Kafka, f'paġna 16.
Konfigurazzjoni tas-sistema tal-avvenimenti: riżorsi
Ir-riżorsa hija fejn tipprovdi d-dettalji kollha tal-konnessjoni (inkluż is-sigriet) meħtieġa biex tilħaq sensar tal-avvenimenti jew endpoint espost minn servizz ta' parti terza. Skont is-sensar/protokoll li trid tuża, tista' tagħżel fost tliet tipi ta' riżorsi tal-avvenimenti default.
- sistema.avveniment.amqp.v1.0.0
- sistema.avveniment.kafka.v1.0.0
- sistema.avveniment.http.v1.0.0
- Innota li hemm sett differenti ta' oqsma ta' konfigurazzjoni għal kull wieħed minnhom
- Għal AMQP, ipprovdi s-ServerDSN fil-format li ġej amqp //localhost 5723.
- Għal Kafka:
- KafkaVersion: Daħħal il-verżjoni ta' Kafka tiegħek. Il-mod standard biex tiċċekkja l-verżjoni ta' Kafka huwa li tħaddem bin/kafka topics.sh version f'terminal.
- Sensara: Daħħal l-indirizzi tas-sensara Kafka tiegħek fil-format li ġej [“localhost 9092”, “192.168.10.9 9092”].
- Settings Oħra: Lista editjabbli bil-valuri tas-settings default ta' Kafka. Tista' timmodifika l-valuri kif meħtieġ. Għal aktar dettalji, ara t-tabella "Kafka Settings Oħra" hawn taħt.
Għall-HTTP:
Tipi ta' avvenimenti ta' prodotti: Imla l- URL qasam u b'mod fakultattiv, Metodu u Intestaturi (pereżempjuample, l-isem u l-valur tal-intestatura tal-ID tal-Klijent bħala oġġett JSON).
Il- URL jeħtieġ li jkun l-indirizz tas-server HTTP tad-destinazzjoni, iżda mingħajr il- URL mogħdija. Int se tidħol fil- URL mogħdija bħala l-Punt tat-tmiem meta tikkonfigura t-tip ta' avveniment.
Nota
Ikkonsma t-tipi ta' avvenimenti: Imla l- URL qasam mas-server URL tal-istanza CWM tiegħek, pereżempjuample, 192.168.10.9 9092.
Ftakar li tipprovdi l- URL tal-istanza CWM tiegħek mingħajr il- URL mogħdija (/avveniment/http). Int se ddaħħal il- URL mogħdija bħala l-Punt tat-tmiem meta tikkonfigura t-tip ta' avveniment.
Tabella 1: Settings Oħra ta' Kafka
| Qasam | Deskrizzjoni |
| ClientID | L-identifikatur użat mill-brokers ta' Kafka biex isegwu s-sors tat-talbiet |
| Verżjoni Kafka | Jispeċifika l-verżjoni ta' Kafka li l-klijent huwa kompatibbli magħha (eż., “2.0.0”) |
| MetadataSħiħa | Meta jkun Veru, iġib il-metadata għas-suġġetti kollha, mhux biss dawk meħtieġa |
| AdminRetryMax | Numru massimu ta' tentattivi mill-ġdid għal talbiet ta' amministratur (eż., ħolqien/tħassir ta' suġġetti) |
| Verżjoni NetSASL | Verżjoni tal-protokoll SASL (Simple Authentication and Security Layer) |
| Sekondi ta' Ħin ta' Skadenza tal-Amministrazzjoni | Timeout f'sekondi għal talbiet ta' amministratur (eż., ħolqien ta' suġġett) |
| ConsumerFetchMin | L-ammont minimu ta' dejta f'bytes li s-sensar għandu jirritorna lill-konsumatur |
| Massimu ta' Tentattivi mill-Ġdid tal-Metadejta | Numru massimu ta' tentattivi biex tinġabar il-metadata (eż., informazzjoni dwar is-suġġett u l-partizzjoni) |
| NetS ASL Tħaddim tal-idejn | Meta jkun Veru, jippermetti l-mekkaniżmu ta' handshake SASL |
| Sekondi ta' Timeout tad-Dial Net | Timeout f'sekondi biex tiġi stabbilita konnessjoni ma' Kafka |
| Ħin Nett tal-Qari f'Sekondi | Timeout f'sekondi għall-qari tad-dejta minn Kafka |
| Sekondi ta' Timeout tal-Kitba Netta | Timeout f'sekondi għall-kitba tad-dejta f'Kafka |
| Sekondi ta' Timeout tal-Produttur | Ħin ta' skadenza f'sekondi għall-produzzjoni ta' messaġġi lil Kafka |
| Default tal-Ġbir tal-Konsumatur | Daqs awtomatiku f'bytes għat-talba tal-konsumatur biex iġib il-prodott (eż., 1MB) |
| Konfermi Meħtieġa mill-Produttur | Jispeċifika n-numru meħtieġ ta' rikonoxximenti mingħand il-brokers biex messaġġ jitqies bħala ta' suċċess (eż., "WaitForLocal") |
| Żbalji fir-Ritorn tal-Produttur | Meta jkun Veru, jippermetti r-rappurtar ta' żbalji għal talbiet ta' prodotti li ma rnexxewx |
| Livell ta' Iżolament tal-Konsumatur | Jispeċifika jekk il-konsumatur jaqrax messaġġi mhux impenjati jew impenjati (“ReadUncommitted” jippermetti l-qari ta' tranżazzjonijiet li jkunu għaddejjin) |
| Kompensazzjonijiet tal-KonsumaturInizjali | Spostament inizjali meta ma jkun hemm l-ebda spostament impenjat (-1 għall-aktar reċenti) |
| Qasam | Deskrizzjoni |
| Talbiet Miftuħa Massimi Netti f'Sekondi | Ħin massimu għal talbiet miftuħa fuq in-netwerk |
Tip ta' avveniment
- Biex toħloq tip ta' avveniment ġdid, jeħtieġ li jkollok riżorsa u sigriet miżjuda mas-CWM.
- L-oqsma li ġejjin huma disponibbli meta żżid tip ta' avveniment:
- Isem tat-tip ta' avveniment: l-isem tat-tip ta' avveniment tiegħek. Aktar tard jissemma fid-definizzjoni tal-fluss tax-xogħol.
- Riżorsa: lista ta' riżorsi li ġew miżjuda qabel ma' CWM.
- Sors tal-avveniment: entrata definita kompletament mill-utent li se tkun irreferenzjata fid-definizzjoni tal-fluss tax-xogħol. Meħtieġ għat-tip ta' avveniment "produce".
- Punt tat-tmiem: l-isem tas-suġġett Kafka (fluss tal-avvenimenti), punt tat-tmiem tal-AMQP (terminus), jew HTTP URL Mogħdija (tal-Ospitanti).
- Nota Għat-tip ta' avveniment ta' konsum HTTP, ipprovdi /event/http bħala l-Punt tat-Tmiem tiegħek.
- Agħżel it-tip: lista li tikkonsisti f'żewġ għażliet: tikkonsma jew tipproduċi t-tip ta' avveniment.
- Nota L-għażla t-tnejn għadha mhix appoġġjata għal CWM.
- Ibda s-semmiegħ (biss għat-tip konsum): immarkah biex tibda tisma' għat-tip ta' avveniment definit.
- Mexxi x-xogħol (biss għat-tip konsumat): immarka din il-kaxxa tal-kontroll jekk trid tattiva fluss tax-xogħol malli tirċievi l-avveniment. Imbagħad agħżel il-fluss tax-xogħol mixtieq mil-lista.
Attributi ta' korrelazzjoni
B'mod fakultattiv, tista' tissettja attributi tal-kuntest għall-avveniment tiegħek. Dawn japplikaw biss għat-tip ta' avveniment ta' konsum u jintużaw biex jattivaw il-flussi tax-xogħol b'mod selettiv. Tista' view jużawhom bħala tip ta' filtri tad-dwana li jirfinaw id-dejta tal-avvenimenti li jidħlu u jidderieġuhom lejn il-flussi tax-xogħol it-tajba li jisimgħu t-tipi ta' avvenimenti b'valuri speċifiċi ta' attributi ta' korrelazzjoni.
Biex iżżid attribut mat-tip ta' avveniment tiegħek, ikklikkja Żid attribut, u agħti isem għall-attribut.
L-attributi tal-korrelazzjoni huma definiti kompletament mill-utent. Jeħtieġ li jaqblu mal-par taċ-ċavetta u l-valur JSON iddikjarat fil-messaġġ tal-avveniment tal-Cloud li għandu jiġi dirett lejn fluss tax-xogħol partikolari.
Format tal-messaġġ tal-avveniment
Il-messaġġi tal-avvenimenti għandhom isegwu l-format tal-ispeċifikazzjoni tal-Cloud Events. Messaġġ ta' avveniment minimu vijabbli li jsegwi l-ispeċifikazzjoni se jkun fih il-parametri li ġejjin:
- {
" - "spezzjoniverżjoni": "1.0",
- “id”: “00001”,
- "tip": "com.github.pull_request.opened",
- "sors": "/sensors/tn-1234567/alerts"
- }
- Il-messaġġ jista' jġorr parametri addizzjonali, bħal “datacontenttype”, “data”, u isem ta' attribut tal-kuntest ta' korrelazzjoni (contextAttrName f'dan l-eżempju).ample):
- {
- "spezzjoni": "1.0",
- “id”: “2763482-4-324-32-4”,
- "tip": "com.github.pull_request.opened",
- "sors": "/sensors/tn-1234567/alerts",
- "tip ta' kontenut tad-dejta": "test/xml",
- "dejta": " ","
- “ContextAttrName”: “ContextAttrValue”
- }
- Definizzjoni u stat tal-avveniment tal-fluss tax-xogħol
- Fid-definizzjoni tal-fluss tax-xogħol, hemm żewġ elementi sintattiċi ewlenin li tuża biex timmaniġġja l-avvenimenti li għalihom il-fluss tax-xogħol se jkun qed jistenna. Dawn huma:
- Id-definizzjoni tal-Avveniment: Użata biex tiddefinixxi t-tip ta' avveniment u l-proprjetajiet tiegħu. Pereżempjuample:
- {
- "isem": "informazzjoni dwar l-applikant",
- "tip": "org.applikazzjoni.info",
- "sors": "sors tal-applikazzjonijiet",
- "korrelazzjoni": [
- {
- “contextAttrName”: “applicantId”
- }
- ]
- }
- • L-Istat tal-Avveniment: Użat biex jiddefinixxi l-azzjonijiet li għandhom jittieħdu meta jseħħ l-avveniment. Pereżempjuample:
- {
- "isem": "MonitorVitals",
- "tip": "avveniment",
- "fuqAvvenimenti": [
- {
- "azzjonijiet": [
- {
- "Ref tal-funzjoni": {
- “refName”: “ittri kbar”,
- “argumenti”: {
- "input": {
- “in”: “il-pazjent ${ .patient } għandu temperatura għolja”
- }
- }
- }
- }
- ],
- "Referenzi tal-avvenimenti": [
- "Temperatura Għolja tal-Ġisem"
- ]
- }
- ]
- }
- Iddefinixxi avveniment ta' Kafka
- Fit-temi li ġejjin, se noħolqu avveniment Kafka u nżiduh ma' fluss tax-xogħol ġdid. L-uniċi prerekwiżiti huma li jrid ikollna:
- Servizz Kafka mwaqqaf kompletament.
- CWM installat.
- Pass 1: Oħloq sigriet ta' Kafka
Biex tippermetti konnessjoni sigura mas-servizz Kafka, trid toħloq sigriet bil-kredenzjali ta' Kafka u riżorsa bid-dettalji tal-konnessjoni.
Proċedura
| Kmand or Azzjoni | Għan | |
| Pass 1 | Fis-CNC, agħżel Amministrazzjoni > Amministrazzjoni tal-Fluss tax-Xogħol > Sigrieti. | |
| Pass 2 | Ikklikkja Żid Sigriet. | |
| Pass 3 | Fil- Sigriet ġdid view, speċifika dan li ġej: | |
| Pass 4 | Wara li tagħżel it-tip ta' sigriet, jintwera sett ta' oqsma addizzjonali taħt Sigriet ittajpja s-sezzjoni tad-dettalji. Imla l-oqsma: | |
| Pass 5 | Ikklikkja Oħloq Sigriet. |
Pass 2: Oħloq riżorsa Kafka
Jeħtieġ ukoll li toħloq riżorsa bid-dettalji tal-konnessjoni.
| Kmand or Azzjoni | Għan | |
| Pass 1 | Fis-CNC, agħżel Amministrazzjoni > Amministrazzjoni tal-Fluss tax-Xogħol > Riżorsi. | |
| Pass 2 | Ikklikkja Żid Riżorsi. |

Pass 3: Żid it-tip ta' avveniment
Meta jkollok is-sigriet u r-riżorsa f'posthom, wasal iż-żmien li tispeċifika t-tip ta' avveniment li se jiġi kkunsmat jew prodott.
Proċedura
| Kmand or Azzjoni | Għan | |
| Pass 1 | Fis-CNC, agħżel Amministrazzjoni > Amministrazzjoni tal-Fluss tax-Xogħol > Tipi ta' Avvenimenti. | |
| Pass 2 | Ikklikkja Żid tip ta' avveniment. | |
| Pass 3 | Fil- Tip ta' avveniment ġdid tieqa, ipprovdi l-input meħtieġ: |

Pass 4: Iddefinixxi l-avveniment f'fluss tax-xogħol
Issa li żidna t-tip ta' avveniment, nistgħu noħolqu fluss tax-xogħol li jirreġistra għal dan it-tip ta' avveniment u jesegwixxi azzjoni meta l-avveniment jiġi riċevut minn CWM. Biex nagħmlu dan, ikollna bżonn:
- Iddefinixxi l-avveniment billi tuża definizzjoni ta' Avveniment.
- Speċifika l-istat tal-Avveniment
- Iddefinixxi l-azzjonijiet li għandhom jittieħdu meta jseħħ l-avveniment.
Bħala exampPereżempju, ejja nieħdu xenarju fejn allarm ta' sħana żejda tar-router (avveniment li dieħel) jattiva stat ta' avveniment wieħed ta' fluss tax-xogħol u jiddefinixxi żewġ azzjonijiet ta' rimedjazzjoni li għandhom jiġu eżegwiti b'reazzjoni għal dak l-istat.
- {
- "id": "Fluss tax-Xogħol ta' Temperazzjoni Għolja tar-Router",
- "isem": "Fluss tax-Xogħol tal-Allarm ta' Tisħin Żejjed tar-Router",
- "bidu": "IrrimedjaTempGħolja",
- "avvenimenti": [
- "tip": "ikkonsmat",
- "isem": "TempRouter Għoli",
- "tip": "TempRouter Għoli",
- "sors": "monitoraġġ.app"
- }
- ],
- “stati”: [
- {
- "tmiem": {
- "temm": veru
- },
- "isem": "IrrimedjaTempGħolja",
- "tip": "avveniment",
- "fuqAvvenimenti": [
- {
- "azzjonijiet": [
- {
- "Ref tal-funzjoni": {
- "refName": "DispatchTech",
- "Attributi tal-kuntest": {
- “RouterIP”: “${ .RouterIP }”
- },
- "ResultEntTimeout": "PT30M"
- }
- }
- ],
- "Referenzi tal-avvenimenti": [
- "Temperatura Għolja tar-Router"
- ]
- },
- {
- "azzjonijiet": [
- {
- "Ref tal-funzjoni": {
- "refName": "MoveTraffic",
- "Attributi tal-kuntest": {
- “RouterIP”: “${ .RouterIP }”
- },
- "ResultEntTimeout": "PT30M"
- }
- }
- ],
- "ħinijiet ta' skadenza": {
- "azzjoniExecTimeout": "PT60M"
- }
- }
- ]
- }
- ],
- "verżjoni": "1.0.0",
- "deskrizzjoni": "Irranġa s-sħana żejda tar-router",
- "Verżjoni tal-ispeċifikazzjoni": "0.8"
Nota
Dan example mhuwiex fluss tax-xogħol komplut. Huwa eżempjuampeżempju ta' kif tiddefinixxi avveniment ġewwa fluss tax-xogħol, tissettja stat sempliċi, u mbagħad tiddefinixxi azzjonijiet li għandhom jittieħdu b'reazzjoni għal dak l-istat wieħed. Fluss tax-xogħol realistiku jista' jiddefinixxi ħafna aktar stati u azzjonijiet li għandhom jittieħdu b'reazzjoni għal kull wieħed minn dawk l-istati.
Dokumenti / Riżorsi
![]() |
Maniġer tal-Fluss tax-Xogħol Crosswork tas-CISCO [pdfGwida għall-Utent Maniġer tal-Fluss tax-Xogħol Crosswork, Maniġer tal-Fluss tax-Xogħol, Maniġer |

