Email Snap batch or delay between sending each message

[peter]

I have a pipeline which sends hundreds of messages, however my email gateway start to block the messages. We this this is because we are logging into the mail account to many times in a short period of time.

Is there a way to batch up the message or have a short delay between sending each message?

[darshthakkar · Accepted solution]

bojanvelevski:

Try this Python script:

# Import the interface required by the Script snap.
from com.snaplogic.scripting.language import ScriptHook
import time
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")
        while self.input.hasNext():
            try:
                # Read the next input document, store it in a new dictionary, and write this as an output document.
                inDoc = self.input.next()
                time.sleep(20)
                outDoc = inDoc
                self.output.write(inDoc, outDoc)
            except Exception as e:
                errDoc = {
                    'error' : str(e)
                }
                self.log.error("Error in python script")
                self.error.write(errDoc)

        self.log.info("Script executed")

    # The "cleanup()" method is called after the snap has exited the execute() method
    def cleanup(self):
        self.log.info("Cleaning up")

# 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)

You can change the delay in the Time.sleep() function. Currently is 20 seconds.

Great solution, thanks @bojanvelevski

[Abhishek_117]

Hi @darshthakkar 
I tried the code,but its taking more than 20 seconds.

[peter]

I get an error when I run the script, Failure: Failed to connect Remote Python Executor,

Do I need to set up an account?
If so where do I get the token?

[bojanvelevski]

Use the Script snap instead of Remote Python Script

[peter]

Worked like a dream.

Thanks