[cybersecurityrtms-3f10] Details

Generated On: 2026-06-03 14:52:30 UTC

TML Solution DAG Parameters' Details: User Chosen Parametets

STEP 1: Get TML Core Params: tml_system_step_1_getparams_dag

User Parameter

Chosen Value

solutionname

cybersecurityrtms-3f10

solutiontitle

Entity-Based Real-Time Advanced Cybersecurity Prevention and Monitoring

solutiondescription

TML Real-Time Memory of Sliding Time Windows For Advanced Cybersecurity Prevention

brokerhost

127.0.0.1

brokerport

9092

cloudusername

None

ingestdatamethod

LOCALFILE

STEP 2: Create Kafka Topics: tml_system_step_2_kafka_createtopic_dag

User Parameter

Chosen Value

companyname

Otics

myname

Sebastian

myemail

Sebastian.Maurice

mylocation

Toronto

replication

1

numpartitions

1

enabletls

1

microserviceid

raw_data_topic

iot-raw-data

preprocess_data_topic

iot-preprocess

ml_data_topic

ml-data

prediction_data_topic

prediction-data

STEP 3: Produce to Kafka Topics

User Parameter

Chosen Value

PRODUCETYPE

LOCALFILE

inputfile

/rawdatademo/cisco_network_data.txt

TOPIC

iot-raw-data

PORT

_39399

IDENTIFIER

TML solution,/rawdatademo/cisco_network_data.txt

HTTPADDR

https://

FROMHOST

('seb', '127.0.1.1')

TOHOST

0.0.0.0

CLIENTPORT

Not Applicable

TSS_CLIENTPORT

Not Applicable

TML_CLIENTPORT

Not Applicable

docfolder

/rawdatademo/mylogsdemo,/rawdatademo/mylogs2demo

doctopic

rtms-stream-mylogs,rtms-stream-mylogs2

chunks

3000

docingestinterval

0

STEP 4: Preprocesing Data: tml-system-step-4-kafka-preprocess-dag

User Parameter

Chosen Value

raw_data_topic

iot-raw-data

preprocess_data_topic

iot-preprocess

preprocessconditions

delay

70

maxrows

800

array

0

saveasarray

1

topicid

-999

rawdataoutput

1

asynctimeout

120

timedelay

0

preprocesstypes

anomprob,trend,avg

pathtotmlattrs

--pathtotmlattrs--

identifier

RTMS Cybersecurity Prevention

jsoncriteria

uid=hostName,filter:allrecords~subtopics=hostName,hostName,hostName~values=inboundpackets,outboundpackets,pingStatus~identifiers=inboundpackets,outboundpackets,pingStatus~datetime=lastUpdated~msgid=~latlong=

STEP 4a: Preprocesing Data: tml-system-step-4a-kafka-preprocess-dag

User Parameter

Chosen Value

raw_data_topic

--raw_data_topic1--

preprocess_data_topic

--preprocess_data_topic1--

preprocessconditions

--preprocessconditions1--

delay

--delay1--

maxrows

--maxrows1--

array

--array1--

saveasarray

--saveasarray1--

topicid

--topicid1--

rawdataoutput

--rawdataoutput1--

asynctimeout

--asynctimeout1--

timedelay

--timedelay1--

preprocesstypes

--preprocesstypes1--

pathtotmlattrs

--pathtotmlattrs1--

identifier

--identifier1--

jsoncriteria

--jsoncriteria1--

STEP 4b: Preprocesing Data: tml-system-step-4b-kafka-preprocess-dag

User Parameter

Chosen Value

raw_data_topic

--raw_data_topic2--

preprocess_data_topic

--preprocess_data_topic2--

preprocessconditions

--preprocessconditions2--

delay

--delay2--

maxrows

--maxrows2--

array

--array2--

saveasarray

--saveasarray2--

topicid

--topicid2--

rawdataoutput

--rawdataoutput2--

asynctimeout

--asynctimeout2--

timedelay

--timedelay2--

preprocesstypes

--preprocesstypes2--

pathtotmlattrs

--pathtotmlattrs2--

identifier

--identifier2--

jsoncriteria

--jsoncriteria2--

STEP 4c: Preprocesing Data: tml-system-step-4c-kafka-preprocess-dag

User Parameter

Chosen Value

raw_data_topic

iot-preprocess

preprocess_data_topic

rtms-preprocess

delay

70

maxrows

200

array

0

saveasarray

1

topicid

-999

rawdataoutput

1

asynctimeout

120

timedelay

0

searchterms

rgx:p([a-z]+)ch ~~~ |authentication failure,--entity-- password failure ~~~ |unknown--entity--

rtmsstream

rtms-stream-mylogs

identifier

RTMS Past Memory of Events

rememberpastwindows

500

patternwindowthreshold

30

localsearchtermfolder

|/rawdatademo/mysearchfile1demo,|/rawdatademo/mysearchfile2demo

localsearchtermfolderinterval

60

rtmsscorethreshold

0.6

rtmsscorethresholdtopic

rtmstopic

attackscorethreshold

0.6

attackscorethresholdtopic

attacktopic

patternscorethreshold

0.6

patternscorethresholdtopic

patterntopic

rtmsfoldername

rtms2

rtmsmaxwindows

1000000

RTMS Output Github Link

Output Data URL

STEP 5: Entity Based Machine Learning : tml-system-step-5-kafka-machine-learning-dag

User Parameter

Chosen Value

preprocess_data_topic

iot-preprocess

ml_data_topic

ml-data

modelruns

--modelruns--

offset

-1

islogistic

--islogistic--

networktimeout

--networktimeout--

modelsearchtuner

--modelsearchtuner--

processlogic

--processlogic--

dependentvariable

--dependentvariable--

independentvariables

--independentvariables--

rollbackoffsets

--rollbackoffsets--

topicid

-999

consumefrom

--consumefrom--

fullpathtotrainingdata

--fullpathtotrainingdata--

transformtype

--transformtype--

sendcoefto

--sendcoefto--

coeftoprocess

--coeftoprocess--

coefsubtopicnames

--coefsubtopicnames--

ML Output Github Link

Output Data URL

STEP 6: Entity Based Predictions: tml-system-step-6-kafka-predictions-dag

User Parameter

Chosen Value

preprocess_data_topic

iot-preprocess

ml_prediction_topic

--ml_prediction_topic--

streamstojoin

--streamstojoin--

inputdata

--inputdata--

consumefrom

--consumefrom2--

offset

-1

delay

70

usedeploy

--usedeploy--

networktimeout

--networktimeout--

maxrows

800

topicid

-999

pathtoalgos

--pathtoalgos--

STEP 7: Real-Time Visualization: tml-system-step-7-kafka-visualization-dag

User Parameter

Chosen Value

vipervizport

9689

topic

rtms-preprocess

dashboardhtml

dashboard-rtms.html

secure

1

offset

-1

append

0

chip

amd64

rollbackoffset

400

STEP 8: tml_system_step_8_deploy_solution_to_docker_dag

User Parameter

Chosen Value

Docker Container

maadsdocker/cybersecurityrtms-3f10-amd64 (https://hub.docker.com/r/maadsdocker/cybersecurityrtms-3f10-amd64)

Docker Run Command

docker run -d --net=host -p 5050:5050 -p 4040:4040 -p 6060:6060

--env TSS=0 --env SOLUTIONNAME=cybersecurityrtms-3f10 --env SOLUTIONDAG=solution_preprocessing_dag-cybersecurityrtms-3f10 --env GITUSERNAME=<Enter Github Username> --env GITPASSWORD='<Enter Github Password>' --env GITREPOURL=<Enter Github Repo URL> --env SOLUTIONEXTERNALPORT=5050 -v /var/run/docker.sock:/var/run/docker.sock:z -v /your_localmachine/foldername:/rawdata:z --env CHIP=amd64 --env SOLUTIONAIRFLOWPORT=4040 --env SOLUTIONVIPERVIZPORT=6060 --env DOCKERUSERNAME='' --env EXTERNALPORT=39399 --env KAFKABROKERHOST=127.0.0.1:9092 --env KAFKACLOUDUSERNAME='<Enter API key>' --env KAFKACLOUDPASSWORD='<Enter API secret>' --env SASLMECHANISM=PLAIN --env VIPERVIZPORT=9689 --env MQTTUSERNAME='' --env MQTTPASSWORD='' --env AIRFLOWPORT=9000 --env READTHEDOCS='<Enter Readthedocs token>' maadsdocker/cybersecurityrtms-3f10-amd64

STEP 9: tml_system_step_9_privategpt_qdrant_dag

User Parameter

Chosen Value

PrivateGPT Container

--pgptcontainername--

PrivateGPT Run Command

--privategptrun--

Qdrant Container

--qdrantcontainer--

Qdrant Run Command

--qdrantrun--

Consumefrom

--consumefrom--

pgpt_data_topic

--pgpt_data_topic--

offset

-1

rollbackoffset

400

topicid

-999

enabletls

1

partition

--partition--

prompt

--prompt--

context

--context--

jsonkeytogather

--jsonkeytogather--

keyattribute

--keyattribute--

keyprocesstype

--keyprocesstype--

vectordbcollectionname

--vectordbcollectionname--

concurrency

--concurrency--

CUDA_VISIBLE_DEVICES

--cuda--

pgpthost

--pgpthost--

pgptport

--pgptport--

hyperbatch

--hyperbatch--

docfolder

--docfolder--

docfolderingestinterval

--docfolderingestinterval--

useidentifierinprompt

--useidentifierinprompt--

searchterms

--searchterms--

streamall

--streamall--

temperature

--temperature--

vectorsearchtype

--vectorsearchtype--

llm

--llmmodel--

embedding

--embedding--

vectorsize

--vectorsize--

contextwindowsize

--contextwindowsize--

vectordimension

--vectordimension--

mitrejson

--mitrejson--

STEP 9b: tml_system_step_9b_agenticai_dag

User Parameter

Chosen Value

rollbackoffset

--agenticai-rollbackoffset--

ollama-model

--agenticai-ollama-model--

deletevectordbcount

--agenticai-deletevectordbcount--

vectordbpath

--agenticai-vectordbpath--

temperature

--agenticai-temperature--

topicid

--agenticai-topicid--

enabletls

--agenticai-enabletls--

partition

--agenticai-partition--

vectordbcollectionname

--agenticai-vectordbcollectionname--

ollamacontainername

--agenticai-ollamacontainername--

mainip

--agenticai-mainip--

mainport

--agenticai-mainport--

embedding

--agenticai-embedding--

agenttopic

--agenticai-agenttopic--

agents_topic_prompt

--agenticai-agents_topic_prompt--

teamlead_topic

--agenticai-teamlead_topic--

teamleadprompt

--agenticai-teamleadprompt--

supervisor_topic

--agenticai-supervisor_topic--

supervisorprompt

--agenticai-supervisorprompt--

agenttoolfunctions

--agenticai-agenttoolfunctions--

agent_team_supervisor_topic

--agenticai-agent_team_supervisor_topic--

concurrency

--agenticai-concurrency--

CUDA_VISIBLE_DEVICES

--agenticai-cuda--

contextwindow

--agenticai-contextwindow--

localmodelsfolder

--agenticai-localmodelsfolder--

STEP 10: tml_system_step_10_documentation_dag

User Parameter

Chosen Value

Solution Documentation URL

https://cybersecurityrtms-3f10.readthedocs.io