from osm_mon.plugins.CloudWatch.plugin_alarm import plugin_alarms
from osm_mon.plugins.CloudWatch.plugin_metric import plugin_metrics
+from osm_mon.plugins.CloudWatch.connection import Connection
+from osm_mon.plugins.CloudWatch.access_credentials import AccessCredentials
from osm_mon.plugins.vRealiseOps import plugin_receiver
# Initialize servers
-server = {'server': 'localhost:9092'}
+if "BROKER_URI" in os.environ:
+ server = {'server': os.getenv("BROKER_URI")}
+else:
+ server = {'server': 'localhost:9092'}
+
+
# Initialize consumers for alarms and metrics
common_consumer = KafkaConsumer(bootstrap_servers=server['server'])
# Create CloudWatch alarm and metric instances
cloudwatch_alarms = plugin_alarms()
cloudwatch_metrics = plugin_metrics()
+aws_connection = Connection()
+aws_access_credentials = AccessCredentials()
#Create vROps plugin_receiver class instance
vrops_rcvr = plugin_receiver.PluginReceiver()
message, openstack_auth, auth_token)
elif vim_type == "aws":
- cloudwatch_metrics.metric_calls(message)
log.info("This message is for the CloudWatch plugin.")
+ aws_conn = aws_connection.setEnvironment()
+ cloudwatch_metrics.metric_calls(message,aws_conn)
elif vim_type == "vmware":
log.info("This metric_request message is for the vROPs plugin.")
openstack_alarms.alarming(message, openstack_auth, auth_token)
elif vim_type == "aws":
- cloudwatch_alarms.alarm_calls(message)
log.info("This message is for the CloudWatch plugin.")
+ aws_conn = aws_connection.setEnvironment()
+ cloudwatch_alarms.alarm_calls(message, aws_conn)
elif vim_type == "vmware":
log.info("This alarm_request message is for the vROPs plugin.")
auth_token = openstack_auth._authenticate(message=message)
elif vim_type == "aws":
- #TODO Access credentials later
log.info("This message is for the CloudWatch plugin.")
+ aws_access_credentials.access_credential_calls(message)
elif vim_type == "vmware":
log.info("This access_credentials message is for the vROPs plugin.")