Function main

python3_cron_scripts/fetch_azure_dns.py:207–287

Begin Main...

(logger=None)

def main(logger=None):
    """
    Begin Main...
    """
    if logger is None:
        logger = LoggingUtil.create_log(__name__)

    now = datetime.now()
    print("Starting: " + str(now))
    logger.info("Starting...")

    azure_connector = AzureConnector.AzureConnector()
    mongo_connector = MongoConnector.MongoConnector()
    dns_manager = DNSManager.DNSManager(mongo_connector)
    zone_ingestor = ZoneIngestor.ZoneIngestor()
    jobs_manager = JobsManager.JobsManager(mongo_connector, "fetch_azure_dns")
    jobs_manager.record_job_start()

    current_zones = ZoneManager.get_distinct_zones(mongo_connector)

    resource_client = azure_connector.get_resources_client()
    resources = []

    # The resource list is not currently used.
    for item in resource_client.resource_groups.list():
        resources.append(item.name)

    dns_client = azure_connector.get_dns_client()

    zones = dns_client.zones.list()

    # The type of records the Azure DNS will let you configure
    record_types = {
        "A": "arecords",
        "AAAA": "aaaa_records",
        "MX": "mx_records",
        "NS": "ns_records",
        "PTR": "ptr_records",
        "SRV": "srv_records",
        "TXT": "txt_records",
        "CNAME": "cname_record",
        "SOA": "soa_record",
    }

    for zone in zones:
        logger.info("Zone: " + zone.name)
        data = split_id(zone.id)

        if zone.zone_type == ZoneType.public:
            logger.info(zone.name + " is public:")

            if zone.name not in current_zones:
                logger.debug("Creating zone: " + zone.name)
                zone_ingestor.add_zone(zone.name, "azure:" + data["resourceGroups"])

            try:
                logger.info("ResourceGroup: " + data["resourceGroups"])
                records = dns_client.record_sets.list_all_by_dns_zone(