By using Apache HOP, you can easily query your local Neo4j database and stream your query output to a Neo4j AuraDB Instance running on a public cloud platform (GPC, AWS).
Here is a step-by-step guide to help you set up a basic pipeline for data steaming into Aura:
- Download the latest version of Apache HOP
- Extract the zip file and start the HOP GUI
Windows:hop-gui.bat
Linux/Mac
# ./hop-gui.sh
- Next create a Neo4j Connection - Aura
Click on Metadata->Neo4j Connection->New
Configure Connection Aura with details according to your environment.
Click the Test connection button at the bottom.
Connection name: Enter a name for your AuraDB connection
In Basic tab:
Automatic? leave blank this checkbox
Server or IP addresses: abcd1234.databases.neo4j.io (this is your connection URI. Find it here)
AuraDB Instance name: neo4j
AuraDB Instnace Port: 7687
Username: your Neo4j AuraDB Instance user name - default is neo4 (superuser)
Password: your Neo4j AuraDB Instance Password
In Protocol tab:
Version 4 AuraDB Instance? check this box if you are running Neo4j version 4 on AuraDB
Browser Port: 7474
Use routing, neo4j:// protocol?: check this checkbox
Routing Policy: Leave this item blank
Use encryption?: check this checkbox
Trust all certificates? : Leave unchecked (this will ensure you validate against a public and registered certificate) - Save to get this connection completed:
- Next Create a new Neo4j Connection to your local Neo4j Database
(repeat steps described above)
In the new connection enter the following:
Connection name: <anonymous name for your AuraDB>
In Basic tab:
Automatic? Check this checkbox
Server or IP addresses: localhost
Database name: neo4j
Database Port: 7687
Username: your Local Neo4j database user name - default is neo4 (superuser)
Password: your-Local-Neo4j-Database-Password
You may leave the Protocol section unchanged since you are using Automatic configuration. - Save your local connection
- Create a pipeline (File->New->Pipeline) with transform: Neo4j Cypher
ON the new/empty canvas, use "Neo4j Cypher" transform to create a pipeline: - Configure "read from localhost"
Transform name: read from localhost
Neo4j Connection: neo4j-local
Batch size (rows): 10
Read-only statement? : check the check box
Reconnect once after disconnection?: check the check box
input cypher statement:
match (p:Person) return p.name as name, p.born as born
- Configure "write to Aura"
Transform name: write to Aura
Neo4j Connection: aura
Collect parameter values map?: check the check box
Read-only statement? : check the check box
Reconnect once after disconnection?: check the check box
Click "Get parameters" Button on the Parameters item card, make sure all the parameter is correct.
input cypher statement:
unwind $rows AS row
MERGE (p:Person (name: row.name})
SET p.born = row.born - Run the pipeline by clicking the start button.
- Check "Transform Metrics" and "Logging" to make sure the data streaming is correctly executed.
- Verify your data loading from AuraDB Instance
Comments
0 comments
Please sign in to leave a comment.