Skip to content

6.3.3 RPM to writers

rod edited this page Aug 15, 2019 · 1 revision

python

All RPM data sent by RPM collecor service to Rabbitmq, is consumend by the RPM to writers service. Messages are parsed for relevant values and translated into neo4j cypher query-like messages. Instead of directly updating the database with these queries, query messages are once again sent to Rabbitmq and there will be services strictly in charge of doing so.

Example of RPM data received (sent by RPM collector):

{
   "originator":"USANYCTEL1R4",
   "source_address":"10.10.21.10",
   "target_address":"10.10.21.9",
   "rtt":"30685"
}

Example of query-like message sent after processing:

MATCH ()-[r:Link {IPv4_Interface_Address:'10.10.21.10'}]->()
  SET r.rtt = 30685