كيف تتخيل الرسم البياني لتكامل الربيع باستخدام Neo4j؟

إطار التكامل الربيعي قادر على إعطاء الحالة الحالية لجميع مكونات EIP وعلاقاتها في شكل رسم بياني JSON. يبدو مناسبًا جدًا للدراسة وتصحيح الأخطاء ، ولكن للأسف ، ليست واحدة من أدوات google (منها مرة واحدة / مرتين فقط ) توفر مرونة كافية لتصور وتحليل هذا الرسم البياني. في هذه المقالة سأوضح كيفية حل هذه المشكلة عن طريق استيراد رسم بياني في نظام Neo4j الرسومية DBMS ، حيث تأتي هذه المرونة أولاً.

أقصر (TL ؛ دكتور)

باختصار ، إليك ما عليك القيام به:

1. قدم عودة الرسم البياني في شكل JSON على عنوان URL معروف.
2. قم بتشغيل طلب Cypher هذا في متصفح Neo4j ، واستبدال URL هناك.

حسنًا ، إذا لم تبدأ للتو أو أصبحت التفاصيل مثيرة للاهتمام ، فمرحباً بك أكثر.

كيفية الحصول على وصف الرسم البياني في JSON؟

هناك طريقتان غير حصريتين:

1. إذا تم استخدام وحدة spring-integration-http(أو spring-integration-webflux) ، فيمكن الحصول على الرسم البياني عن طريق سحب وحدة تحكم الرسم البياني للدمج .
2. إذا تم استخدام وحدة spring-integration-core معا مع الحذاء المحرك الربيع، ثم الرسم البياني يمكن الحصول من خلال لنقطة النهاية دعا integrationgraph (والتي افتراضيا لا يمكن الوصول إليها عبر شبكة الإنترنت).

في كلتا الحالتين ، ستبدو الإجابة على النحو التالي:

{
  "contentDescriptor": {
    "providerVersion": "5.2.4.RELEASE",
    "providerFormatVersion": 1.1,
    "provider": "spring-integration",
    "name": "analog"
  },
  "nodes": [
    {
      "nodeId": 3,
      "componentType": "ExecutorSubscribableChannel",
      "name": "brokerChannel"
    },
    // ...
  ],
  "links": [
    {
      "from": 19,
      "to": 8,
      "type": "output"
    },
    // ...
  ]
}

3 :

• contentDescriptor – ; name ( spring.application.name).
• nodes – EIP-, . name, componentType nodeId, , .
• links , .. EIP-. from to nodeId . type , 5: input, output, route, error, discard.

( EIP) !
, , , componentType channel.

Spring Integration.

Neo4j, - , , , http://localhost:8080/actuator/integrationgraph ( Spring Boot Actuator). JSON, , .

CORS, . Spring Boot (+Actuator) , :

management:
  endpoints:
    web:
      exposure:
        include: '*'
      cors:
        allowed-origins: '*'
        allowed-methods: '*'

( production!)

Spring Integration, . .

Neo4j?

Neo4j, 2 :

1. Neo4j (, ?)
   :

   
   
   • Neo4j Desktop
   • Neo4j Community Server
   • Neo4j Sandbox
     
   
   

2. Cypher- APOC

   
   

   - Neo4j, . Neo4j Sandbox .

   
   

Neo4j 4.0.1, , . APOC , 2 Neo4j.

1:

Spring Integration, JSON-, , “ ” : – , – , – . : nodeId, nodeName componentType. org.springframework.integration.graph.IntegrationNode, ( ).

, Neo4j - :

JSON URL, .

Cypher :

// (1) load JSON from URL:
WITH "http://localhost:8080/actuator/integrationgraph" AS url
CALL apoc.load.json(url) YIELD value      
WITH value AS json, value.contentDescriptor AS jsonDescriptor
// (2) descriptor:
MERGE (descriptor:Descriptor {name: jsonDescriptor.name})
    ON CREATE SET
    descriptor.providerVersion = jsonDescriptor.providerVersion,
    descriptor.providerFormatVersion = jsonDescriptor.providerFormatVersion,
    descriptor.provider = jsonDescriptor.provider
// (3) nodes:
WITH json, descriptor
UNWIND json.nodes AS jsonNode
MERGE (node:Node {nodeId: jsonNode.nodeId})
    ON CREATE SET
    node.componentType = jsonNode.componentType,
    node.name = jsonNode.name
// (4) links:
WITH json, descriptor, node
UNWIND json.links AS jsonLink
MATCH (a:Node {nodeId: jsonLink.from}), (b:Node {nodeId: jsonLink.to})
MERGE (a)-[link:Link {type: jsonLink.type}]->(b)
// (5) result:
RETURN descriptor, node, link

Cypher, ( ):

1. APOC- apoc.load.json(url) JSON- json, – jsonDescriptor.
2. Descriptor, jsonDescriptor.
   MERGE, , . , MERGE CREATE.
3. JSON- ( nodes) UNWIND Node, name componentType.
4. ( links), Link MATCH, .
5. , : , .

Neo4j Browser JSON-, :

-, : EIP- , , Neo4j Browser, , Cypher-:

“” ( ) , . , .

, :

• , EIP- , , , , , serverR... , , , .
• , Link, type. , Cypher, “ ” .
• , , , – , .

, , , …

2:

, : , , . Neo4j Browser ( , ), GraSS (Graph Style Sheet), Neo4j Browser’. , , :style ( ):

. Neo4j Browser , , ( ) Node. Neo4j Browser, , . “” EIP-: , , .. , , , Cypher- - “ ” . , Cypher “ ” : – , . APOC. apoc.merge.node, / , :

merge nodes with dynamic labels, with support for setting properties ON CREATE or ON MATCH

: , /, – , . , Cypher- , “” , , channel. CASE.

: -, , -, JSON- Cypher MERGE, APOC – apoc.merge.relationship:

merge relationship with dynamic type, with support for setting properties ON CREATE or ON MATCH

, - “” , , , , , – , . , , , . , “” . DESCRIBES - .

, , :

// (1) load JSON from URL:
WITH "http://localhost:8080/actuator/integrationgraph" AS url
CALL apoc.load.json(url) YIELD value
WITH value AS json, value.contentDescriptor AS jsonDesc
// (2) descriptor:
MERGE (descriptor:Descriptor {name: jsonDesc.name})
  ON CREATE SET
    descriptor.providerVersion = jsonDesc.providerVersion,
    descriptor.providerFormatVersion = jsonDesc.providerFormatVersion,
    descriptor.provider = jsonDesc.provider,
    descriptor.updated = localdatetime()
  ON MATCH SET
    descriptor.updated = localdatetime()
// (3) nodes:
WITH json, descriptor
UNWIND json.nodes AS jsonNode
CALL apoc.merge.node(
  /*labels*/ ['Node',
    CASE
      WHEN jsonNode.componentType IS NULL THEN "<unknown>"
      WHEN toLower(jsonNode.componentType) ENDS WITH "channel" THEN "channel"
      WHEN toLower(jsonNode.componentType) ENDS WITH "adapter" THEN "adapter"
      WHEN jsonNode.componentType CONTAINS '$' THEN "<other>"
      ELSE jsonNode.componentType
    END],
  /*identProps*/   {nodeId: jsonNode.nodeId, appName: descriptor.name},
  /*onCreateProps*/{name: jsonNode.name, componentType: jsonNode.componentType},
  /*onMatchProps*/ {}
) YIELD node
MERGE (descriptor)-[:DESCRIBES]->(node)
// (4) links:
WITH json, descriptor, node
UNWIND json.links AS jsonLink
MATCH (a:Node {nodeId: jsonLink.from})<-[:DESCRIBES]-(descriptor)-[:DESCRIBES]->(b:Node {nodeId: jsonLink.to})
CALL apoc.merge.relationship(a, toUpper(jsonLink.type), {}, {}, b, {}) YIELD rel
// (5) result:
RETURN descriptor

, - 5 ( ):

1. JSON ;
2. / , ;

3. / , Node ( - ), :

   
   
   • <unknown>, (, , , , , UnzipTransformer);
   • channel, channel, , ExecutorSubscribableChannel;
   • adapter, adapter, , inbound-channel-adapter;
   • <other>, $, ( ) , , ServerConfig$$Lambda$994/0x00000008010fd440;
   • , , , "componentType": "gateway".
     componentType . DESCRIBES.
   
   
4. / , type JSON- .
   . , , nodeId. , appName .
5. .
   , , - . .

Spring Integration, ( 350+ 330+ , . ). Neo4j , , , :

Neo4j , . , Neo4j bin/neo4j-admin, memrec , , .

, GraSS- (, ) Neo4j Browser’, :style.

, MATCH (a) RETURN a, - . , , , . ( name):

WITH "analog" AS appName
MATCH (:Descriptor {name: appName})-[:DESCRIBES]->(n:Node)-[l*0..1]-(:Node)
RETURN n, l

, , ( ). , .

:

, . Cypher- (. .4 ), style.grass, componentType Node. , . , GraSS- EIP- :

node.Node {
  defaultCaption: "<id>";
  caption: "{name}";
}

Neo4j Browser – :

. , , Neo4j Browser, . .

, Neo4j Spring Integration. , , , :

, JSON- EIP- Spring Integration. Neo4j . Cypher “ ” , . . , ( ) Cypher-, .

– Neo4j Browser. , ; , . , – . Cypher , . , //, / , , / / , / .. , .

مقال تمييز Cypher الأصلي هنا .