79 строки
3.5 KiB
YAML
79 строки
3.5 KiB
YAML
id: 87890d78-3e05-43ec-9ab9-ba32f4e01250
|
|
name: (Preview) TI map Domain entity to SecurityAlert
|
|
description: |
|
|
'Identifies a match in SecurityAlert table from any Domain IOC from TI'
|
|
severity: Medium
|
|
requiredDataConnectors:
|
|
- connectorId: ThreatIntelligence
|
|
dataTypes:
|
|
- ThreatIntelligenceIndicator
|
|
- connectorId: ThreatIntelligenceTaxii
|
|
dataTypes:
|
|
- ThreatIntelligenceIndicator
|
|
- connectorId: MicrosoftCloudAppSecurity
|
|
dataTypes:
|
|
- SecurityAlert
|
|
- connectorId: AzureSecurityCenter
|
|
dataTypes:
|
|
- SecurityAlert
|
|
queryFrequency: 1h
|
|
queryPeriod: 14d
|
|
triggerOperator: gt
|
|
triggerThreshold: 0
|
|
tactics:
|
|
- Impact
|
|
query: |
|
|
|
|
let dt_lookBack = 1h;
|
|
let ioc_lookBack = 14d;
|
|
//Create a list of TLDs in our threat feed for later validation
|
|
let list_tlds = ThreatIntelligenceIndicator
|
|
| where TimeGenerated > ago(ioc_lookBack)
|
|
| where isnotempty(DomainName)
|
|
| extend parts = split(DomainName, '.')
|
|
| extend tld = parts[(array_length(parts)-1)]
|
|
| summarize count() by tostring(tld)
|
|
| summarize make_list(tld);
|
|
ThreatIntelligenceIndicator
|
|
| where TimeGenerated >= ago(ioc_lookBack) and ExpirationDateTime > now()
|
|
| where Active == true
|
|
// Picking up only IOC's that contain the entities we want
|
|
| where isnotempty(DomainName)
|
|
| join (
|
|
SecurityAlert
|
|
| where TimeGenerated > ago(dt_lookBack)
|
|
//Extract domain patterns from message
|
|
| extend domain = extract("(([a-z0-9]+(-[a-z0-9]+)*\\.)+[a-z]{2,})", 1, tolower(Entities))
|
|
| where isnotempty(domain)
|
|
| extend parts = split(domain, '.')
|
|
//Split out the TLD
|
|
| extend tld = parts[(array_length(parts)-1)]
|
|
//Validate parsed domain by checking if the TLD is in the list of TLDs in our threat feed
|
|
| where tld in~ (list_tlds)
|
|
// Converting Entities into dynamic data type and use mv-expand to unpack the array
|
|
| extend EntitiesDynamicArray = parse_json(Entities) | mv-expand EntitiesDynamicArray
|
|
// Parsing relevant entity column extract hostname and IP address
|
|
| extend EntityType = tostring(parse_json(EntitiesDynamicArray).Type), EntityAddress = tostring(EntitiesDynamicArray.Address), EntityHostName = tostring(EntitiesDynamicArray.HostName)
|
|
| extend HostName = iif(EntityType == 'host', EntityHostName, '')
|
|
| extend IP_addr = iif(EntityType == 'ip', EntityAddress, '')
|
|
| extend Alert_TimeGenerated = TimeGenerated
|
|
| extend Alert_Description = Description
|
|
) on $left.DomainName==$right.domain
|
|
| where Alert_TimeGenerated >= TimeGenerated and Alert_TimeGenerated < ExpirationDateTime
|
|
| summarize LatestIndicatorTime = arg_max(TimeGenerated, *) by IndicatorId
|
|
| project LatestIndicatorTime, Description, ActivityGroupNames, IndicatorId, ThreatType, ExpirationDateTime, ConfidenceScore, Alert_TimeGenerated, AlertName, Alert_Description, ProviderName, AlertSeverity, ConfidenceLevel, HostName, IP_addr, Url
|
|
| extend timestamp = Alert_TimeGenerated, HostCustomEntity = HostName, IPCustomEntity = IP_addr, URLCustomEntity = Url
|
|
entityMappings:
|
|
- entityType: Host
|
|
fieldMappings:
|
|
- identifier: FullName
|
|
columnName: HostCustomEntity
|
|
- entityType: IP
|
|
fieldMappings:
|
|
- identifier: Address
|
|
columnName: IPCustomEntity
|
|
- entityType: URL
|
|
fieldMappings:
|
|
- identifier: Url
|
|
columnName: URLCustomEntity
|
|
version: 1.0.0 |