Kubernetes 云原生实战：分布式 GeaFlow 实现图研发，构建第一个商业智能应用

MATCH (:TagClass where name = 'Comedian')      <-[:hasType]-(:Tag)      <-[:hasTag]-(msg:Post|Comment)

MATCH (:Tag)      <-[:hasTag]-(msg:Post)      <-[:hasCreator]-(person:Person)      -[:knows]-{0,1}(friend:Person)

kubectl cluster-info

Kubernetes master is running at https://172.25.8.152:6443

hdfs getconf -namenodes

hadoop org.apache.hadoop.conf.Configuration | grep 'fs.defaultFS'

CREATE GRAPH IF NOT EXISTS bi (  Vertex Tag (id bigint ID, name varchar, url varchar),  Vertex Person (id bigint ID,  creationDate bigint,  firstName varchar,  lastName varchar,                 gender varchar,  browserUsed varchar,  locationIP varchar),  Vertex Post (id bigint ID,  creationDate bigint,  browserUsed varchar,  locationIP varchar,               content varchar, length bigint,  lang varchar, imageFile varchar),  Edge hasType (srcId bigint SOURCE ID, targetId bigint DESTINATION ID),  Edge hasTag (srcId bigint SOURCE ID,  targetId bigint DESTINATION ID),  Edge hasInterest (srcId bigint SOURCE ID, targetId bigint DESTINATION ID),  Edge hasCreator (srcId bigint SOURCE ID,  targetId bigint DESTINATION ID),  Edge knows (srcId bigint SOURCE ID, targetId bigint DESTINATION ID, creationDate bigint)) WITH (    storeType='rocksdb');

Create Table If Not Exists tbl_Person (id bigint, type varchar, creationDate bigint, firstName varchar,    lastName varchar, gender varchar, browserUsed varchar, locationIP varchar)WITH ( type='file', geaflow.dsl.file.path='/tmp/data/bi_person');INSERT INTO bi.PersonSELECT id, creationDate, firstName, lastName, gender, browserUsed, locationIP FROM tbl_Person;
Create Table If Not Exists tbl_edge_va (srcId bigint, targetId bigint, type varchar, va bigint)WITH ( type='file', geaflow.dsl.file.path='/tmp/data/bi_edge_with_value');
INSERT INTO bi.knows SELECT srcId, targetId, va FROM tbl_edge_va WHERE type = 'knows';

CREATE TABLE IF NOT EXISTS tbl_interest_tag(personId bigint, personName varchar, tagId bigint, tagName varchar)WITH (    type='file',    geaflow.dsl.file.path='/tmp/geaflow/chk/result/interest_tag');
USE GRAPH bi;
INSERT INTO tbl_interest_tagMATCH (person:Person)-[:hasInterest]->(tag:Tag)RETURN person.id as personId, concat(person.lastName, person.firstName) as personName,       tag.id as tagId, tag.name as tagNameORDER BY personId, tagId LIMIT 100;

CREATE TABLE IF NOT EXISTS tbl_centrality_score(personId bigint, personName varchar, tagId bigint, tagName varchar, personCentralityScore bigint)WITH (    type='file',    geaflow.dsl.file.path='/tmp/geaflow/chk/result/tag_centrality_score');
USE GRAPH bi;
INSERT INTO tbl_centrality_scoreMATCH (interest_tag:Tag)<-[:hasInterest]-(person:Person)LET person.hasInterest = COUNT((person:Person)-[:hasInterest]->(tag where id = interest_tag.id) => tag.id)LET person.messageScore = COUNT((person:Person)                                <-[:hasCreator]-(message:Post|Comment)                                -[:hasTag]->(tag where id = interest_tag.id)                                => tag.id)LET person.score = person.messageScore + IF(person.hasInterest > 0, 100, 0)RETURN person.id as personId, concat(person.lastName, person.firstName) as personName,       interest_tag.id as tagId, interest_tag.name as tagName, person.score as personCentralityScoreORDER BY personId, personCentralityScore DESC LIMIT 100;

CREATE TABLE IF NOT EXISTS tbl_person_centrality (  personId bigint,  score bigint,  friendsScore bigint) WITH (    type='file',    geaflow.dsl.file.path='/tmp/geaflow/chk/result/person_centrality');
USE GRAPH bi;
INSERT INTO tbl_person_centralityMATCH (person:Person)--tag.name = 'Huang Bo' tag.id = 1020002LET person.hasInterest = COUNT((person:Person)-[:hasInterest]->(tag where id = 1020002) => tag.id)LET person.messageScore = COUNT((person:Person)                                <-[:hasCreator]-(message:Post|Comment                                where creationDate > 1672502400000 and creationDate < 1696160400000)                                -[:hasTag]->(tag where id = 1020002)                                => tag.id)LET GLOBAL person.score = person.messageScore + IF(person.hasInterest > 0, 100, 0)MATCH (person:Person)-[:knows]-{0,1}(friend:Person)RETURN person.id as personId, person.score as personCentralityScore,SUM(IF(friend.id = person.id, CAST(0 as BIGINT), CAST(friend.score as BIGINT))) as friendScoreGROUP BY personId, personCentralityScoreORDER BY personCentralityScore + friendScore DESC, personId LIMIT 100;