|
@@ -23,7 +23,7 @@ logger.addHandler(fileHandler)
|
|
|
logger.setLevel(level=logging.INFO)
|
|
|
class LogWallpad(Resource):
|
|
|
def post(self):
|
|
|
- producer = KinesisProducer(stream_name='ambt-preden-test',boto3_session=session)
|
|
|
+ producer = KinesisProducer(stream_name=os.environ['STREAM'],boto3_session=session)
|
|
|
request.json['site']=os.environ['SITE']
|
|
|
logger.info(json.dumps(request.json))
|
|
|
producer.put(json.dumps(request.json)+'\n')
|