async def fetch_malware_data_and_ingest_to_log_analytics(self, indicators_data):
        """Create async tasks and fetch the malware data asynchronously.

        Args:
            indicators_data (dict): Indicators data from cofense
        """
        __method_name = inspect.currentframe().f_code.co_name
        try:
            proxy_data = self.malware_proxy()
            get_malware_url = "{}{}".format(
                consts.COFENSE_BASE_URL, consts.ENDPOINTS["get_malware"]
            )
            threat_ids = set()
            for indicator in indicators_data.get("data", {}).get("indicators", []):
                threat_ids.add(indicator.get("threat_id", ""))
            applogger.info(threat_ids)
            tasks = []
            async with aiohttp.ClientSession() as session:
                for threat in threat_ids:
                    tasks.append(
                        asyncio.create_task(
                            self.get_malware_data(
                                threat_id=threat,
                                malware_url=get_malware_url,
                                session=session,
                                proxy_data=proxy_data,
                            )
                        )
                    )
                results = await asyncio.gather(*tasks, return_exceptions=True)
            success_count = 0
            failed_count = 0
            success_malware_data = []
            for i in results:
                if not isinstance(i, CofenseIntelligenceException):
                    success_count += 1
                    success_malware_data.append(i)
                else:
                    failed_count += 1
            applogger.info(
                "{}(method={}) : {} : Total_Invocations: {}, Successful Malware Fetching: {}, \
                    Failed Malware Fetching: {}.".format(
                    consts.LOGS_STARTS_WITH,
                    __method_name,
                    consts.COFENSE_MALWARE_DATA_TO_LOG_ANALYTICS,
                    len(results),
                    success_count,
                    failed_count,
                )
            )
            if len(success_malware_data) > 0:
                post_data(
                    body=json.dumps(success_malware_data),
                    log_type=consts.MALWARE_DATA_TABLE_NAME,
                )
                applogger.info(
                    "{}(method={}) : {} : Posted Malware Data to Log Analytics Successfully.".format(
                        consts.LOGS_STARTS_WITH,
                        __method_name,
                        consts.COFENSE_MALWARE_DATA_TO_LOG_ANALYTICS,
                    )
                )
            else:
                applogger.info(
                    "{}(method={}) : {} : No Malware Data found.".format(
                        consts.LOGS_STARTS_WITH,
                        __method_name,
                        consts.COFENSE_MALWARE_DATA_TO_LOG_ANALYTICS,
                    )
                )

        except CofenseIntelligenceException as error:
            applogger.error(
                "{}(method={}) : {} : error occured : {}.".format(
                    consts.LOGS_STARTS_WITH,
                    __method_name,
                    consts.COFENSE_MALWARE_DATA_TO_LOG_ANALYTICS,
                    error,
                )
            )
            raise CofenseIntelligenceException()
Create async tasks and fetch the malware data asynchronously.

        Args:
            indicators_data (dict): Indicators data from cofense
        
Solutions/CofenseIntelligence/Data Connectors/CofenseIntelligenceDataConnector/CofenseIntelligenceMalware/cofense_malware_data_to_sentinel.py