David Fauth davidfauth

## docker-compose-4_0.yml
version: '3'

networks:
  lan:

services:

  core1:
    image: neo4j:4.0.0-alpha10-enterprise
    networks:

## Neo4j-Databricks-Example.txt
#Step 1
%python
#write a file to DBFS using Python I/O APIs
with open("/dbfs/tmp/neo4_test.csv", 'w') as f:
  f.write("id,name,emp_id,employer\n")
  for x in range(500):
    f.write(str(x) + ",name_" + str(x) + "," + str(x) + ",emp_name_" + str(x) + "\n")
  f.close()

#Step 2 Load to Dataframe

## SparkToNeo4j.html
<!DOCTYPE html>
<html>
<head>
  <meta name="databricks-html-version" content="1">
<title>Neo4j Chicago Crime Notebook - Databricks</title>

<meta charset="utf-8">
<meta name="google" content="notranslate">
<meta name="robots" content="nofollow">
<meta http-equiv="Content-Language" content="en">

## kafka_neo4j_ssl.adoc

      
              1 file
            
          
              0 forks
            
          
              0 comments
            
          
              0 stars
            
          
                davidfauth
                / kafka_neo4j_ssl.adoc
            
            
              Created
              October 14, 2019 12:58
            
              
                Kafa Neo4j SSL Configuration
              
          
Overview:


This document, Neo4j Security with Kafka Streams, provides guidance to configure SSL security between Kafka and Neo4j. This will provide data encryption between Kafka and Neo4j.


This does not address ACL confguration inside of KAFKA.


Self Signed Certificates


This section came from https://medium.com/talking-tech-all-around/how-to-enable-and-verify-client-authentication-in-kafka-21e936e670e8

Make sure that you have truststore and keystore JKSs for each server.+
In case you want a self signed certificate, you can use the following commands:+


## neo4jfourloadexample.py
### neo4jfourloadexample.py
### 22 April 2020
### David Fauth
### @davefauth


import os
import sys
import csv
from io import StringIO

## testgist
import json
from py2neo import authenticate, Graph, NodeSelector, Node, Relationship
import sys
import time
from neo4j import GraphDatabase


def run_cypher_query(tx, query):
	return tx.run(query)

## neo4j.conf.gist
dbms.default_listen_address=0.0.0.0
dbms.default_advertised_address=xxx.xxx.xxx.xxx

# Bolt connector
dbms.connector.bolt.enabled=true
dbms.connector.bolt.tls_level=REQUIRED
dbms.connector.bolt.listen_address=:17687
dbms.connector.bolt.advertised_address=:17687

# HTTP Connector. There can be zero or one HTTP connectors.

## neo4j_4_docker_ssl
version: '3'

networks:
  lan:

services:

  core1:
    image: neo4j:4.0.4-enterprise
    networks:

## neo4j_rbac_example.cql
// RBAC Example

// Nodes -> Person / Phone / Email / Account
// Relationships -> :HAS_PHONE / :HAS_EMAIL / :HAS_ACCOUNT
// Roles -> Manager / ServiceRep / NoAccount
// Users -> John / Sally / George

// Code

:USE system

## neo4j-wcc-example.cyp
// Data was randomly generated data

// Create the Graph
CALL gds.graph.create(
    'wcc-graph', {
        Customer: { label: 'Customer' },
        Email: { label: 'Email' },
        Phone: { label: 'Phone' }
    },
    {
	version: '3'

	networks:
	lan:

	services:

	core1:
	image: neo4j:4.0.0-alpha10-enterprise
	networks:
	#Step 1
	%python
	#write a file to DBFS using Python I/O APIs
	with open("/dbfs/tmp/neo4_test.csv", 'w') as f:
	f.write("id,name,emp_id,employer\n")
	for x in range(500):
	f.write(str(x) + ",name_" + str(x) + "," + str(x) + ",emp_name_" + str(x) + "\n")
	f.close()

	#Step 2 Load to Dataframe
	<!DOCTYPE html>
	<html>
	<head>
	<meta name="databricks-html-version" content="1">
	<title>Neo4j Chicago Crime Notebook - Databricks</title>

	<meta charset="utf-8">
	<meta name="google" content="notranslate">
	<meta name="robots" content="nofollow">
	<meta http-equiv="Content-Language" content="en">
	### neo4jfourloadexample.py
	### 22 April 2020
	### David Fauth
	### @davefauth


	import os
	import sys
	import csv
	from io import StringIO
	import json
	from py2neo import authenticate, Graph, NodeSelector, Node, Relationship
	import sys
	import time
	from neo4j import GraphDatabase



	def run_cypher_query(tx, query):
	return tx.run(query)
	dbms.default_listen_address=0.0.0.0
	dbms.default_advertised_address=xxx.xxx.xxx.xxx

	# Bolt connector
	dbms.connector.bolt.enabled=true
	dbms.connector.bolt.tls_level=REQUIRED
	dbms.connector.bolt.listen_address=:17687
	dbms.connector.bolt.advertised_address=:17687

	# HTTP Connector. There can be zero or one HTTP connectors.
	// RBAC Example

	// Nodes -> Person / Phone / Email / Account
	// Relationships -> :HAS_PHONE / :HAS_EMAIL / :HAS_ACCOUNT
	// Roles -> Manager / ServiceRep / NoAccount
	// Users -> John / Sally / George

	// Code

	:USE system
	// Data was randomly generated data

	// Create the Graph
	CALL gds.graph.create(
	'wcc-graph', {
	Customer: { label: 'Customer' },
	Email: { label: 'Email' },
	Phone: { label: 'Phone' }
	},
	{