8min
Configure the Agent
Enter the kensu_ingestion_token in the conf.ini file:
ini
|
Here is the code before we add Kensu:
Scala
|
1️⃣ Init Kensu in your code
First, we create a Spark session, adding the Kensu JAR file.
Scala
|
2️⃣Create Connection to Kensu
SparkSessionDAMWrapper creates a connection between the Spark job and Kensu in order to send the events through the API.
Scala
|
3️⃣ Send metadata to Kensu
Then we write the data to the Kensu cloud using the join()function. Then we save the data model in a Parquet file and sends metadata, profiling and lineage to Kensu:
Scala
|
Here is the Complete code
Scala
|


Updated 07 Nov 2022
Did this page help you?
Yes
No