فهرست منبع

스트림이름,호스트 아이피 환경변수로 대체

heewon 3 سال پیش
والد
کامیت
b0a322dd1b
1فایلهای تغییر یافته به همراه1 افزوده شده و 1 حذف شده
  1. 1 1
      flask_app/app.py

+ 1 - 1
flask_app/app.py

@@ -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')