s3-batch-process-sigma-3.js

/* 
This function publishes the provided message with subject to the notification
topic and excute the provided onSuccess or onFailure callback handler 
*/
exports.sendNotification = (subject, message, onSuccess, onFailure) => {
	sns.publish({
		Message: message,
		Subject: subject,
		MessageAttributes: {},
		MessageStructure: 'String',
		TopicArn: 'arn:aws:sns:us-east-1:YOUR_ACCOUNT_ID:batch-process-notify'
	}).promise()
		.then(data => {
			console.log("Successfully published notification");
			onSuccess();
		})
		.catch(err => {
			console.log("Error occurred while publishing notification", err, err.stack);
			onFailure(err);
		});

}