Best practices to publish to a AWS SNS topic

Hi Mohamed,

I had the same requirement with sns that you had posted. So if i follow the approach that you mentioned here it will be good right?
Or any additional step to be taken.

Regards,
Hirak

Hi,
We used the same approacj and it was working fine for past few months.But now am getting below error.

ailure: Cannot evaluate Script file: # Import the interface required by the Script snap. from com.snaplogic.scripting.language import ScriptHook import java.util from java.lang import System import sys sys.path.append(‘/opt/snaplogic/ext_jar/aws-java-sdk-1.11.788.jar’) from com.amazonaws.services.sns import AmazonSNSClient from com.amazonaws.regions import Region from com.amazonaws.regions import Regions from com.amazonaws import AmazonClientException from com.amazonaws import AmazonServiceException from com.amazonaws.services.sns.model import CreateTopicRequest from com.amazonaws.services.sns.model import CreateTopicResult from com.amazonaws.services.sns.model import SubscribeRequest from com.amazonaws.services.sns.model import PublishRequest from com.amazonaws.services.sns.model import PublishResult from com.amazonaws.services.sns.model import DeleteTopicRequest class TransformScript(ScriptHook): def init(self, input, output, error, log): self.input = input self.output = output self.error = error self.log = log # The “execute()” method is called once when the pipeline is started # and allowed to process its inputs or just send data to its outputs. def execute(self): self.log.info(“Executing Transform script”) # Specify security credentials explecitly props = System.getProperties() props.setProperty(“aws.accessKeyId”, “”) props.setProperty(“aws.secretKey”, “”) # create a new SNS client and set endpoint snsClient = AmazonSNSClient() snsClient.setRegion(Region.getRegion(Regions.US_WEST_2)) while self.input.hasNext(): try: # Read the next document, wrap it in a map and write out the wrapper in_doc = self.input.next() # Specify security credentials explecitly props = System.getProperties() props.setProperty(“aws.accessKeyId”, in_doc[‘accessKeyId’]) props.setProperty(“aws.secretKey”, in_doc[‘secretKey’]) # create a new SNS client and set endpoint snsClient = AmazonSNSClient() snsClient.setRegion(Region.getRegion(Regions.US_WEST_2)) # publish to an SNS topic publishRequest = PublishRequest(in_doc[‘topicArn’], in_doc[‘msg’]) publishResult = snsClient.publish(publishRequest) #Put the incoming message in a wrapper object to write it to output stream wrapper = java.util.HashMap() wrapper[‘original’] = in_doc self.output.write(in_doc, wrapper) except Exception as e: errWrapper = { ‘errMsg’ : str(e.args) } self.log.error(“Error in python script”) self.error.write(errWrapper) self.log.info(“Finished executing the Transform script”) # The Script Snap will look for a ScriptHook object in the “hook” # variable. The snap will then call the hook’s “execute” method. hook = TransformScript(input, output, error, log), Reason: ImportError: No module named sns in at line number 8, Resolution: Please fix the script file error at line: 8 column: -1