TerribleDev/TimberWinR
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Simplified

Browse Source
This commit is contained in:
Eric Fontana
2014-07-23 13:16:58 -04:00
parent 223d15cd8d
commit 97ea89497c
2 changed files with 8 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
TimberWinR.ServiceHost/sampleconf.xml
View File

@@ -19,11 +19,9 @@
<AddTag>rn_%{RecordNumber}</AddTag>
<AddTag>bar</AddTag>
</Grok>
<!-- <Mutate>
<Rename oldName="timestamp" newName="xtimestamp"/>
<Remove field="foo%{Index}" />
<Mutate>
<Rename oldName="TimeGenerated" newName="timestamp"/>
</Mutate>
-->
<Date field="timestamp" target="@timestamp" convertToUTC="true">
<Pattern>MMM d HH:mm:ss</Pattern>
<Pattern>MMM dd HH:mm:ss</Pattern>

36
TimberWinR/Filters/MutateFilter.cs
View File

@@ -114,37 +114,13 @@ namespace TimberWinR.Filters
public override void Apply(JObject json)
{
json = RenameProperty(json, name => name == OldName ? NewName : name) as JObject;
}
private static JToken RenameProperty(JToken json, Dictionary<string, string> map)
{
return RenameProperty(json, name => map.ContainsKey(name) ? map[name] : name);
}
private static JToken RenameProperty(JToken json, Func<string, string> map)
{
JProperty prop = json as JProperty;
if (prop != null)
JToken token = json[OldName];
if (token != null)
{
return new JProperty(map(prop.Name), RenameProperty(prop.Value, map));
}
JArray arr = json as JArray;
if (arr != null)
{
var cont = arr.Select(el => RenameProperty(el, map));
return new JArray(cont);
}
JObject o = json as JObject;
if (o != null)
{
var cont = o.Properties().Select(el => RenameProperty(el, map));
return new JObject(cont);
}
return json;
}
json.Remove(OldName);
json.Add(NewName, token);
}
}
}
}
}