def insert_stream_sns()

in PythonKafkaSink/main.py [0:0]

• 2 lines of code
• 1 McCabe index (conditional complexity)

def insert_stream_sns(insert_from, insert_into):
    return """ INSERT INTO {1}