Gems/AWSMetrics/cdk/aws_metrics/aws_metrics_stack.py [32:76]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                 id_: str,
                 application_name: str,
                 optional_features: dict,
                 **kwargs) -> None:
        super().__init__(scope, id_, **kwargs)

        self._data_ingestion = DataIngestion(self, application_name)

        self._real_time_data_processing = RealTimeDataProcessing(
            self,
            input_stream_arn=self._data_ingestion.input_stream_arn,
            application_name=application_name
        )

        batch_processing_enabled = optional_features.get('batch_processing', False)
        server_access_logs_bucket = optional_features.get('server_access_logs_bucket')
        self._data_lake_integration = DataLakeIntegration(
            self,
            application_name=application_name,
            server_access_logs_bucket=server_access_logs_bucket
        ) if batch_processing_enabled else None

        self._batch_processing = BatchProcessing(
            self,
            input_stream_arn=self._data_ingestion.input_stream_arn,
            application_name=application_name,
            analytics_bucket_arn=self._data_lake_integration.analytics_bucket_arn,
            events_database_name=self._data_lake_integration.events_database_name,
            events_table_name=self._data_lake_integration.events_table_name
        ) if batch_processing_enabled else None

        self._batch_analytics = BatchAnalytics(
            self,
            application_name=application_name,
            analytics_bucket_name=self._data_lake_integration.analytics_bucket_name,
            events_database_name=self._data_lake_integration.events_database_name,
            events_table_name=self._data_lake_integration.events_table_name
        ) if batch_processing_enabled else None

        self._dashboard = Dashboard(
            self,
            input_stream_name=self._data_ingestion.input_stream_name,
            application_name=application_name,
            analytics_processing_lambda_name=self._real_time_data_processing.analytics_processing_lambda_name,
            delivery_stream_name=self._batch_processing.delivery_stream_name if batch_processing_enabled else '',
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



Gems/AWSMetrics/cdv1/aws_metrics/aws_metrics_stack.py [31:75]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                 id_: str,
                 application_name: str,
                 optional_features: dict,
                 **kwargs) -> None:
        super().__init__(scope, id_, **kwargs)

        self._data_ingestion = DataIngestion(self, application_name)

        self._real_time_data_processing = RealTimeDataProcessing(
            self,
            input_stream_arn=self._data_ingestion.input_stream_arn,
            application_name=application_name
        )

        batch_processing_enabled = optional_features.get('batch_processing', False)
        server_access_logs_bucket = optional_features.get('server_access_logs_bucket')
        self._data_lake_integration = DataLakeIntegration(
            self,
            application_name=application_name,
            server_access_logs_bucket=server_access_logs_bucket
        ) if batch_processing_enabled else None

        self._batch_processing = BatchProcessing(
            self,
            input_stream_arn=self._data_ingestion.input_stream_arn,
            application_name=application_name,
            analytics_bucket_arn=self._data_lake_integration.analytics_bucket_arn,
            events_database_name=self._data_lake_integration.events_database_name,
            events_table_name=self._data_lake_integration.events_table_name
        ) if batch_processing_enabled else None

        self._batch_analytics = BatchAnalytics(
            self,
            application_name=application_name,
            analytics_bucket_name=self._data_lake_integration.analytics_bucket_name,
            events_database_name=self._data_lake_integration.events_database_name,
            events_table_name=self._data_lake_integration.events_table_name
        ) if batch_processing_enabled else None

        self._dashboard = Dashboard(
            self,
            input_stream_name=self._data_ingestion.input_stream_name,
            application_name=application_name,
            analytics_processing_lambda_name=self._real_time_data_processing.analytics_processing_lambda_name,
            delivery_stream_name=self._batch_processing.delivery_stream_name if batch_processing_enabled else '',
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -