diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-10-11 11:47:39 +0200 |
|---|---|---|
| committer | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-10-25 16:42:27 +0200 |
| commit | c4ce5ebb7de6494cb8d90076cba8596aa0cbabeb (patch) | |
| tree | 13756bd08650c0e41e24132b8dab0fad327ddf31 /opendc-trace/opendc-trace-azure | |
| parent | ff94e63d5f80df317505c7ae0c6a5465f9a0c1f5 (diff) | |
feat(trace): Support conversion from Azure trace format
This change adds support for converting the Azure VM traces into the
OpenDC trace format.
Diffstat (limited to 'opendc-trace/opendc-trace-azure')
2 files changed, 2 insertions, 2 deletions
diff --git a/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceStateTableReader.kt b/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceStateTableReader.kt index da8181fe..94a91999 100644 --- a/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceStateTableReader.kt +++ b/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceStateTableReader.kt @@ -53,7 +53,7 @@ internal class AzureResourceStateTableReader(private val parser: CsvParser) : Ta when (parser.currentName) { "timestamp" -> timestamp = Instant.ofEpochSecond(parser.longValue) "vm id" -> id = parser.text - "CPU avg cpu" -> cpuUsagePct = parser.doubleValue + "CPU avg cpu" -> cpuUsagePct = (parser.doubleValue / 100.0) // Convert from % to [0, 1] } } diff --git a/opendc-trace/opendc-trace-azure/src/test/kotlin/org/opendc/trace/azure/AzureTraceFormatTest.kt b/opendc-trace/opendc-trace-azure/src/test/kotlin/org/opendc/trace/azure/AzureTraceFormatTest.kt index b73bb728..eda0b214 100644 --- a/opendc-trace/opendc-trace-azure/src/test/kotlin/org/opendc/trace/azure/AzureTraceFormatTest.kt +++ b/opendc-trace/opendc-trace-azure/src/test/kotlin/org/opendc/trace/azure/AzureTraceFormatTest.kt @@ -77,7 +77,7 @@ class AzureTraceFormatTest { { assertTrue(reader.nextRow()) }, { assertEquals("+ZcrOp5/c/fJ6mVgP5qMZlOAGDwyjaaDNM0WoWOt2IDb47gT0UwK9lFwkPQv3C7Q", reader.get(RESOURCE_ID)) }, { assertEquals(0, reader.get(RESOURCE_STATE_TIMESTAMP).epochSecond) }, - { assertEquals(2.86979, reader.getDouble(RESOURCE_STATE_CPU_USAGE_PCT), 0.01) } + { assertEquals(0.0286979, reader.getDouble(RESOURCE_STATE_CPU_USAGE_PCT), 0.01) } ) reader.close() |