I realize this is a year later, but I thought you might like to know that what you're looking for actually exists.   It's not my repo but I've been using them, and plan to update the documentation to make them a little more user friendly.   Hope this helps.   https://github.com/paulgibeault/SnowflakeNiFiProcessors   ... View more

Admittedly I know very little about DynamoDB, but I don't think it provides a native method to pull the entire table.    If this is a one-time task, I suppose you could export your table to S3, and then use the FetchS3 nifi processor to get it into your flow.   If you're looking to process new records as they arrive, I suppose you could use lambda to push the new records into Kafka or Kinesis and use nifi to consume that queue.   There is also a way (which I have not explored) to use HiveQL with EMR for querying DynamoDB tables.   Assuming that works how I *think* it works, you could then use the SelectHiveQL processor to pull your DynamoDB table into your nifi flow.   I've also never used EMR, but maybe it will be a fun experiment? ... View more

Thanks for this writeup.  I was having a heck of a time authenticating, was expecting the authentication keys to be separate fields in the processor configuration.   I didn't realize you could add all that right in the connection string, although it leaves your passwords in plain text.   Seems like an opportunity for improvement. ... View more