public void writeDataToAtlasCluster(
|
final String pMongoUri,
|
final String pDataLakeCollection,
|
final String pDataLakeDatabase,
|
final String pAtlasCollectionName,
|
final String pAtlasDatabaseName,
|
final String pClusterName) {
|
final MongoClient mongoClient = new MongoClient(new MongoClientURI((pMongoUri)));
|
mongoClient
|
.getDatabase(pDataLakeDatabase)
|
.getCollection(pDataLakeCollection)
|
.aggregate(
|
List.of(
|
new Document()
|
.append(
|
"$out",
|
new Document(
|
"atlas",
|
new Document()
|
.append("clusterName", pClusterName)
|
.append("db", pAtlasDatabaseName)
|
.append("coll", pAtlasCollectionName))))).toCollection();
|
}
|