es_receiver.py 文件源码

def index_fingerprint(sender, instance, **kwargs):
    """Process facts using engine and convert to fingerprints.

    :param sender: Class that was saved
    :param instance: SystemFingerprint that was saved
    :param kwargs: Other args
    :returns: None
    """
    # pylint: disable=unused-argument

    timestamp = time.time()
    timestamp = int(round(timestamp * 1000))

    es_fingerprint = FingerPrintIndex(
        fact_collection=instance.id,
        connection_host=instance.connection_host,
        connection_port=instance.connection_port,
        connection_uuid=instance.connection_uuid,
        cpu_count=instance.cpu_count,
        cpu_core_per_socket=instance.cpu_core_per_socket,
        cpu_siblings=instance.cpu_siblings,
        cpu_hyperthreading=instance.cpu_hyperthreading,
        cpu_socket_count=instance.cpu_socket_count,
        cpu_core_count=instance.cpu_core_count,
        system_creation_date=instance.system_creation_date,
        infrastructure_type=instance.infrastructure_type,
        os_name=instance.os_name,
        os_version=instance.os_version,
        os_release=instance.os_release,
        virtualized_is_guest=instance.virtualized_is_guest,
        virtualized_type=instance.virtualized_type,
        virtualized_num_guests=instance.virtualized_num_guests,
        virtualized_num_running_guests=instance.virtualized_num_running_guests,
        timestamp=timestamp)

    try:
        es_fingerprint.save()
    except RequestError as error:
        logger.error('%s failed to persist fingerprint: %s\n%s',
                     __name__, es_fingerprint, error)