/usr/local/WowzaStreamingEngine/lib/wse-plugin-s3upload.jar
/usr/local/WowzaStreamingEngine/lib/aws-java-sdk-1.11.804.jar

/usr/local/WowzaStreamingEngine/lib/wse-plugin-s3upload.jar /usr/local/WowzaStreamingEngine/lib/aws-java-sdk-1.11.804.jar

import json
import urllib.parse
import boto3
import pymysql
from pprint import pprint
print('Loading function')
s3 = boto3.client('s3')
#--------------------
#rds settings
rds_host  = "mydbtest.caeuqamozgcm.ap-northeast-1.rds.amazonaws.com"
name = "admin"
password = "123456"
db_name = "test"
 
try:
    connection = pymysql.connect(rds_host, user=name, passwd=password, db=db_name, connect_timeout=5)
except pymysql.MySQLError as e:
    print("ERROR: Unexpected error: Could not connect to MySQL instance. " + e)
 
print("SUCCESS: Connection to RDS MySQL instance succeeded")
#--------------------
 
def lambda_handler(event, context):
    #print("Received event: " + json.dumps(event, indent=2))
 
    # Get the object from the event and show its content type
    bucket = event['Records'][0]['s3']['bucket']['name']
    print("EVENT:")
    pprint(event)
    #bucket = "moviesync-plggd"
    key = urllib.parse.unquote_plus(event['Records'][0]['s3']['object']['key'], encoding='utf-8')
    print("KEY:" + key)
 
    #--------------------
    # insert mysql
    try:
        with connection.cursor() as cursor:
            # Create a new record
            sql = "INSERT INTO `tb_files` (`name`, `status`,`uploaded`) VALUES (%s, %s, NOW())"
            cursor.execute(sql, (key, 1))
        # connection is not autocommit by default. So you must commit to save your changes.
        connection.commit()
    finally:
        connection.close()
    #--------------------
 
    try:
        response = s3.get_object(Bucket=bucket, Key=key)
        print("CONTENT TYPE: " + response['ContentType'])
        return response['ContentType']
    except Exception as e:
        print(e)
        print('Error getting object {} from bucket {}. Make sure they exist and your bucket is in the same region as this function.'.format(key, bucket))
        raise e

import json import urllib.parse import boto3 import pymysql from pprint import pprint print('Loading function') s3 = boto3.client('s3') #-------------------- #rds settings rds_host = "mydbtest.caeuqamozgcm.ap-northeast-1.rds.amazonaws.com" name = "admin" password = "123456" db_name = "test" try: connection = pymysql.connect(rds_host, user=name, passwd=password, db=db_name, connect_timeout=5) except pymysql.MySQLError as e: print("ERROR: Unexpected error: Could not connect to MySQL instance. " + e) print("SUCCESS: Connection to RDS MySQL instance succeeded") #-------------------- def lambda_handler(event, context): #print("Received event: " + json.dumps(event, indent=2)) # Get the object from the event and show its content type bucket = event['Records'][0]['s3']['bucket']['name'] print("EVENT:") pprint(event) #bucket = "moviesync-plggd" key = urllib.parse.unquote_plus(event['Records'][0]['s3']['object']['key'], encoding='utf-8') print("KEY:" + key) #-------------------- # insert mysql try: with connection.cursor() as cursor: # Create a new record sql = "INSERT INTO `tb_files` (`name`, `status`,`uploaded`) VALUES (%s, %s, NOW())" cursor.execute(sql, (key, 1)) # connection is not autocommit by default. So you must commit to save your changes. connection.commit() finally: connection.close() #-------------------- try: response = s3.get_object(Bucket=bucket, Key=key) print("CONTENT TYPE: " + response['ContentType']) return response['ContentType'] except Exception as e: print(e) print('Error getting object {} from bucket {}. Make sure they exist and your bucket is in the same region as this function.'.format(key, bucket)) raise e