diff --git a/idk/kafka/cmd_test.go b/idk/kafka/cmd_test.go index f3cd26477..645db6948 100644 --- a/idk/kafka/cmd_test.go +++ b/idk/kafka/cmd_test.go @@ -638,6 +638,60 @@ func TestCmdSchemaChange(t *testing.T) { } } +func TestTimeQuantums(t *testing.T) { + + /* + at a high level, a test here represents + - an avro schema + - a set of records to ingest to kafka + - an ingest configuration + - query to run to confirm the data was ingest properly + */ + tests := []struct { + name string + autoGenerateID bool + primaryKeyFields string // nil when idField is not nil + idField string // nil when primaryKeyFields is not nil + PilosaHosts []string + RegistryURL string + pathToAvroSchema string + pathToRecords string + topic string + }{ + { + name: "time quantums exist", + autoGenerateID: false, + primaryKeyFields: "device", + idField: nil, + PilosaHosts []string + RegistryURL string + pathToAvroSchema string + pathToRecords string + topic string // don't duplicate + + }, + { + name: "3 primary keys str/str/int TLS", + PrimaryKeyFields: []string{"abc", "db", "user_id"}, + PilosaHosts: []string{pilosaTLSHost}, + TLS: &idk.TLSConfig{ + CertificatePath: certPath + "/theclient.crt", + CertificateKeyPath: certPath + "/theclient.key", + CACertPath: certPath + "/ca.crt", + EnableClientVerification: true, + }, + expRhinoKeys: []string{"2|1|159", "4|3|44", "123456789|q2db_1234|432"}, // "2" + "1" + uint32(159) + + }, + { + name: "IDField int", + IDField: "user_id", + expRhinoCols: []uint64{44, 159, 432}, + }, + } + +} + type sortableCRI []pilosaclient.CountResultItem func (s sortableCRI) Len() int { return len(s) } diff --git a/idk/kafka/testdata/records/timeQuantum.txt b/idk/kafka/testdata/records/timeQuantum.txt new file mode 100644 index 000000000..ba0d8458d --- /dev/null +++ b/idk/kafka/testdata/records/timeQuantum.txt @@ -0,0 +1,500 @@ +{'device': 'XbJ7vwASddz1xBQ4', 'segment_ts': 'fub2', 'time_q': '2023-02-13 18:11:08'} +{'device': 'g3AwJJUDwrN1LYzY', 'segment_ts': 'Qn3I', 'time_q': '2023-02-13 19:39:01'} +{'device': 'DIxrncsISTdUJdsH', 'segment_ts': 'o8Ig', 'time_q': '2023-01-27 09:41:54'} +{'device': 'yR1RUTVnjwUvjWLS', 'segment_ts': 'BUnG', 'time_q': '2023-01-25 06:55:04'} +{'device': 'dpeJtjO0mVsN3wiZ', 'segment_ts': 'Udwh', 'time_q': '2023-01-25 14:34:42'} +{'device': 'hOJrFi9xmOnM5J2B', 'segment_ts': '9jED', 'time_q': '2023-01-27 17:05:19'} +{'device': 'xPLZ3qjA029BWoD8', 'segment_ts': 'PBbR', 'time_q': '2023-02-17 08:47:05'} +{'device': 'sdnPNO80Trlnkfpi', 'segment_ts': 'ACVo', 'time_q': '2023-02-21 09:01:47'} +{'device': 'fcMcP2T8hIBzYzrB', 'segment_ts': 'HppX', 'time_q': '2023-02-18 00:59:36'} +{'device': 'xiRO1wD8bdg6tsy2', 'segment_ts': 'iSQp', 'time_q': '2023-01-28 06:15:59'} +{'device': 'nlsTgLlvTBhQGewH', 'segment_ts': 'CZHg', 'time_q': '2023-02-20 18:53:14'} +{'device': 'bpLtS0dLbzC1t0aM', 'segment_ts': 'oanZ', 'time_q': '2023-02-11 08:25:43'} +{'device': 'RcYtSPPTAQyOE80E', 'segment_ts': '57He', 'time_q': '2023-02-14 06:40:17'} +{'device': 'BLqS1Js4hqpAGKbs', 'segment_ts': '8Esc', 'time_q': '2023-02-13 01:59:32'} +{'device': 'NDJ13gRlrfjSpJul', 'segment_ts': 'fBcm', 'time_q': '2023-01-24 07:05:02'} +{'device': 'CUS2BbP8fJrBuJRB', 'segment_ts': 'kUK0', 'time_q': '2023-02-05 22:33:45'} +{'device': 'lwC1KW3eNMX7kqwS', 'segment_ts': '8s12', 'time_q': '2023-02-15 19:55:08'} +{'device': 'jtEPRgME5UKtmv2O', 'segment_ts': 'Ew1L', 'time_q': '2023-02-10 10:44:56'} +{'device': 'zJJQ58p1vZEVr8pV', 'segment_ts': 'cb9G', 'time_q': '2023-01-31 14:49:08'} +{'device': 'zGLCqlcb9WEVYeTD', 'segment_ts': 'JatF', 'time_q': '2023-02-19 17:37:42'} +{'device': 'PgyMZVp5lPVUAzju', 'segment_ts': 'H4w7', 'time_q': '2023-01-25 01:13:51'} +{'device': 'KS2ftxZpJaobrFcH', 'segment_ts': 'lzde', 'time_q': '2023-02-08 07:29:00'} +{'device': 'pvfQ90NOCNxkZ9qp', 'segment_ts': 'meI7', 'time_q': '2023-02-01 09:29:32'} +{'device': 'et0tVgDi4gQLBbCZ', 'segment_ts': '8roi', 'time_q': '2023-02-17 13:59:05'} +{'device': 'KVpmUGw3YFQWFKUJ', 'segment_ts': 'reQ2', 'time_q': '2023-02-07 05:12:56'} +{'device': '7e62NVroqaZ5KCCG', 'segment_ts': 'mRqe', 'time_q': '2023-01-25 18:55:33'} +{'device': '2jhbxRtroaywIHz0', 'segment_ts': 'vGvz', 'time_q': '2023-01-31 06:31:33'} +{'device': 'i8A3oSUCLIRVI3z6', 'segment_ts': 'bRK7', 'time_q': '2023-01-22 15:45:16'} +{'device': 'w9m2zmvBebNOYm7M', 'segment_ts': 'EUTl', 'time_q': '2023-02-12 17:45:44'} +{'device': '6goOWv6GmSB5SImL', 'segment_ts': 'IcRw', 'time_q': '2023-02-02 19:44:49'} +{'device': '9TdRfZY8fyUv0MDA', 'segment_ts': 'jxeF', 'time_q': '2023-02-15 12:46:23'} +{'device': 'XFT7MaPT04gy9giN', 'segment_ts': 'NDT5', 'time_q': '2023-01-27 02:02:09'} +{'device': 'dYf2esJeNHts76qt', 'segment_ts': 'nD5r', 'time_q': '2023-02-20 19:18:20'} +{'device': 'XO3Mw07kTWxq4S6A', 'segment_ts': 'wu98', 'time_q': '2023-02-19 09:11:04'} +{'device': 'PR20MB3DrKZyxBYN', 'segment_ts': 'VxO2', 'time_q': '2023-02-14 02:48:28'} +{'device': '8HoHoySkF3ONDVMT', 'segment_ts': 'RZW0', 'time_q': '2023-02-17 09:47:36'} +{'device': 'D9EMY6KMiUupVo86', 'segment_ts': 'uKvn', 'time_q': '2023-02-13 20:34:37'} +{'device': '6vw27rBMy4z08u0H', 'segment_ts': 'IhoS', 'time_q': '2023-02-07 21:19:31'} +{'device': '8B3tax9WJNOuceOO', 'segment_ts': '2sCg', 'time_q': '2023-02-13 06:09:00'} +{'device': 'q1kmQxWdgK1fI2Aq', 'segment_ts': 'tpUd', 'time_q': '2023-01-22 22:14:51'} +{'device': 'VPe3DuOwKmbOf9hj', 'segment_ts': 'Q1EB', 'time_q': '2023-02-07 01:49:40'} +{'device': 'bcn6NL9OVcDI9NOE', 'segment_ts': 'pmBn', 'time_q': '2023-02-06 19:24:58'} +{'device': 'xveWOtVYpFmdKoE3', 'segment_ts': '3pUE', 'time_q': '2023-01-29 05:45:06'} +{'device': 'O9p8Ij6SiXU7w9Bo', 'segment_ts': 'wDD7', 'time_q': '2023-02-07 02:09:17'} +{'device': 'JU1KI8rx8qLXtY9Y', 'segment_ts': 'NBSG', 'time_q': '2023-02-15 13:20:17'} +{'device': 'zvc3NHLWCKRbwL4w', 'segment_ts': 'wAqp', 'time_q': '2023-02-06 19:57:45'} +{'device': 'uIKOal9xGdwgmxQZ', 'segment_ts': '3x0X', 'time_q': '2023-02-19 00:21:42'} +{'device': '0Rn9nBxCnr1abKBu', 'segment_ts': 'K3q7', 'time_q': '2023-02-07 03:02:30'} +{'device': 'DcPFdJzT9aCgD7hZ', 'segment_ts': '1WZE', 'time_q': '2023-02-04 22:53:14'} +{'device': 'I33U4ld8p1ZTEo2z', 'segment_ts': 'h327', 'time_q': '2023-02-15 09:02:02'} +{'device': 'HzV2F1u15P6MfTq4', 'segment_ts': 'Oi4K', 'time_q': '2023-02-18 03:07:18'} +{'device': 'Gs8bQMX2wl9AjM5I', 'segment_ts': 'CT5V', 'time_q': '2023-02-16 01:45:58'} +{'device': 'aPv5uNdC2x9Zrs31', 'segment_ts': 'ijS2', 'time_q': '2023-01-29 20:43:50'} +{'device': 'gmBMopHkBCbcGRaS', 'segment_ts': 'nD5r', 'time_q': '2023-02-11 05:05:58'} +{'device': 'g3Ns2caZMQVlOSPr', 'segment_ts': '9vzm', 'time_q': '2023-01-27 00:22:33'} +{'device': 'JWY6hPLwnhy76KGZ', 'segment_ts': '2IS2', 'time_q': '2023-02-11 21:47:10'} +{'device': '0QKtSTqJYXMZWvVe', 'segment_ts': '7R83', 'time_q': '2023-02-17 05:40:55'} +{'device': 'Ximq2ebfKR1eqySD', 'segment_ts': 'Jpup', 'time_q': '2023-01-23 17:34:53'} +{'device': 'YWGLIrHDKwe6UUM1', 'segment_ts': 'Smbg', 'time_q': '2023-02-11 22:29:38'} +{'device': 'i8Hy1Hhy6vbQ7Gnj', 'segment_ts': 'Xjn9', 'time_q': '2023-02-07 05:52:25'} +{'device': 'trQjczSWWWqD3xip', 'segment_ts': 'zSyE', 'time_q': '2023-02-14 03:51:05'} +{'device': 'cRAvzL88YU74zOVR', 'segment_ts': 'FAk3', 'time_q': '2023-02-02 06:26:40'} +{'device': 'H7RUb4moxDU5RY8L', 'segment_ts': '6sUs', 'time_q': '2023-02-06 15:29:02'} +{'device': 'g6uZFROq6hA9VwXU', 'segment_ts': '9v3C', 'time_q': '2023-01-30 05:29:57'} +{'device': 'yIGidxsJbbyaTMJu', 'segment_ts': '5TbD', 'time_q': '2023-01-31 20:18:06'} +{'device': 'DC9B8r6fLUrQEKWd', 'segment_ts': 'VDz6', 'time_q': '2023-02-09 22:19:07'} +{'device': 'rymp2l5MJvVdAEiU', 'segment_ts': 'fyte', 'time_q': '2023-02-02 11:53:13'} +{'device': 'Ua1gF72JZ4WAc8Bd', 'segment_ts': 'v5sp', 'time_q': '2023-01-24 02:06:04'} +{'device': '9qSO5sST0XGp5jMS', 'segment_ts': '7dBw', 'time_q': '2023-02-10 09:35:42'} +{'device': 'p0HAiSpiSNAaCrZB', 'segment_ts': 'a1iQ', 'time_q': '2023-01-31 15:45:28'} +{'device': 'wkYtecM7PdltlJ6U', 'segment_ts': 'tCye', 'time_q': '2023-01-29 14:50:59'} +{'device': 'efTNUHAxzw90hiOb', 'segment_ts': '9Wf1', 'time_q': '2023-02-18 02:29:02'} +{'device': 'fQI3EBaehVoTHSuQ', 'segment_ts': 'zRBT', 'time_q': '2023-02-11 19:06:37'} +{'device': 'udeapVgb384YhUvm', 'segment_ts': 'oL67', 'time_q': '2023-02-05 10:27:36'} +{'device': 'eqbom6mcHS60rV4o', 'segment_ts': 'GNdZ', 'time_q': '2023-02-11 08:44:18'} +{'device': '1wWPwlCsbs9ZBcZC', 'segment_ts': 'zaKC', 'time_q': '2023-02-08 00:49:32'} +{'device': 'ecY2Gsp5o5y8RDEy', 'segment_ts': 'QWzq', 'time_q': '2023-01-29 02:43:04'} +{'device': 'DxqHMz1dx4Bqsobg', 'segment_ts': '2RQv', 'time_q': '2023-02-18 21:50:04'} +{'device': 'XU1b7NOcHSuGzCUv', 'segment_ts': 'Yuoy', 'time_q': '2023-02-13 21:54:55'} +{'device': 'lO2wwnU1eJPm8GXQ', 'segment_ts': 'AP3b', 'time_q': '2023-01-28 14:02:06'} +{'device': 'tLnTsvtbSVqjrYe9', 'segment_ts': 'fFTT', 'time_q': '2023-01-24 23:23:30'} +{'device': 'BD3RZkRDscI24QIW', 'segment_ts': '3Bry', 'time_q': '2023-02-14 17:16:33'} +{'device': 'EJTuSaV3BN56Wj2O', 'segment_ts': 'W4JQ', 'time_q': '2023-02-01 18:56:00'} +{'device': 'TfinqcstHOBc9vgU', 'segment_ts': 'VybU', 'time_q': '2023-01-30 13:41:42'} +{'device': 'oLCaL36jSe58AJzI', 'segment_ts': '28pM', 'time_q': '2023-02-03 07:47:20'} +{'device': 'I85aiLVze3vm3TkQ', 'segment_ts': 'y8y1', 'time_q': '2023-02-19 19:12:25'} +{'device': 'J1Z6A5uaqDbcJCfB', 'segment_ts': 'Wzwh', 'time_q': '2023-02-10 08:51:06'} +{'device': 'DUJWSG7TcQrG1SiU', 'segment_ts': 'qKgC', 'time_q': '2023-02-18 22:00:14'} +{'device': 'oq4StgCLUoilIYHQ', 'segment_ts': 'MNLg', 'time_q': '2023-02-05 10:11:01'} +{'device': 'P44lydZpIGjbmQOy', 'segment_ts': 'uHCR', 'time_q': '2023-01-22 21:38:00'} +{'device': '8lV1uEL9zdwqOuwT', 'segment_ts': '8wB6', 'time_q': '2023-02-05 21:52:08'} +{'device': 'uVGi6rqE7NKl7D0W', 'segment_ts': 'kge3', 'time_q': '2023-02-12 14:45:28'} +{'device': 'fBDDRmw5ifz9Ibk1', 'segment_ts': 'e8wv', 'time_q': '2023-02-12 01:36:43'} +{'device': 'q8q2AXRsgPrtU7MF', 'segment_ts': 'lznG', 'time_q': '2023-01-31 09:08:30'} +{'device': 'rKVwah03kvEN1Xf8', 'segment_ts': 'CIf7', 'time_q': '2023-02-17 15:32:01'} +{'device': '5gqkkJu0HnW8e7Jd', 'segment_ts': '11VE', 'time_q': '2023-02-21 12:50:18'} +{'device': '67aeTL1Lhk7zPniw', 'segment_ts': '7WnQ', 'time_q': '2023-02-15 09:54:03'} +{'device': 'JSqkbIUNs9XsDhyf', 'segment_ts': 'Vef3', 'time_q': '2023-01-28 05:40:03'} +{'device': 'O6pY363lkXtNFnPW', 'segment_ts': 'JPG3', 'time_q': '2023-02-09 07:18:08'} +{'device': 'tpldKtJXhNOJs5is', 'segment_ts': 'x40J', 'time_q': '2023-02-19 03:15:47'} +{'device': 'zJFXIMKFyyMjvHzJ', 'segment_ts': 'ddlX', 'time_q': '2023-02-12 02:18:47'} +{'device': 'o0W2DatNPhPHeUCG', 'segment_ts': '3Lzx', 'time_q': '2023-02-01 03:05:37'} +{'device': '0qNRr7JlwEJo0UZs', 'segment_ts': 'x1R8', 'time_q': '2023-02-04 16:06:55'} +{'device': 'ybv2vBmnJIMXDQ7C', 'segment_ts': 'DyAY', 'time_q': '2023-02-04 14:33:24'} +{'device': '7bkYnhDEWrdlKPzi', 'segment_ts': 'CHYf', 'time_q': '2023-02-18 13:52:19'} +{'device': 'gS5FFLJPIgSpPn2p', 'segment_ts': '73ea', 'time_q': '2023-02-20 13:38:30'} +{'device': 'Iz5J7QbGpOaw9Mc3', 'segment_ts': 'UD8U', 'time_q': '2023-02-19 21:56:03'} +{'device': 'Q4zAccg3hJyiWPQV', 'segment_ts': 'WbDH', 'time_q': '2023-02-19 21:57:53'} +{'device': 'vwowDnNJnQ3Noych', 'segment_ts': 'YyvE', 'time_q': '2023-02-07 21:35:53'} +{'device': 'V4Yg3xtwNAdXT7AC', 'segment_ts': 'OQ1f', 'time_q': '2023-01-27 03:41:03'} +{'device': 'kBcU57h5YJlps0M7', 'segment_ts': 'X9xH', 'time_q': '2023-02-16 21:18:05'} +{'device': 'mTOckeiB1Myp9PzA', 'segment_ts': 'wDD7', 'time_q': '2023-02-16 06:44:48'} +{'device': 'jFqBXPPMyJJaM4VG', 'segment_ts': 'csTs', 'time_q': '2023-02-06 02:52:21'} +{'device': 'vKNH7K6ozve7702k', 'segment_ts': 'SJ25', 'time_q': '2023-02-08 01:27:29'} +{'device': 'oyT2TtgfCba2Hdml', 'segment_ts': 'Tvqb', 'time_q': '2023-02-21 03:13:30'} +{'device': 'rsOlS9C8eEy347rZ', 'segment_ts': 'hr7p', 'time_q': '2023-02-19 02:30:46'} +{'device': '90GjHMWLi1dcpp0y', 'segment_ts': 'W4JQ', 'time_q': '2023-01-25 02:29:48'} +{'device': 'fvudPtjiPgFEJ7bD', 'segment_ts': 'lwno', 'time_q': '2023-01-24 05:44:13'} +{'device': 'VBWAgZvfVhht5RLf', 'segment_ts': 'Ftw2', 'time_q': '2023-01-27 13:08:57'} +{'device': 'sZK0cJqcYBnZXwyj', 'segment_ts': '9G1V', 'time_q': '2023-01-27 21:13:09'} +{'device': 'Nw2Qbh1azig2aS8i', 'segment_ts': 'VPUK', 'time_q': '2023-02-20 06:55:48'} +{'device': 'YrmDmrxR6yVVsmBK', 'segment_ts': 'kEmM', 'time_q': '2023-02-17 04:13:52'} +{'device': 'FJg8emti6uDPkZWb', 'segment_ts': 'cu9S', 'time_q': '2023-01-31 15:15:17'} +{'device': 'D2KVrcXONfBL0DOq', 'segment_ts': 'E7q4', 'time_q': '2023-02-07 05:21:14'} +{'device': 'zpjzEqsoIDSfgkrw', 'segment_ts': 'kuSy', 'time_q': '2023-02-08 21:39:35'} +{'device': 'TyBhOHhPHg3mABfs', 'segment_ts': 'FOLC', 'time_q': '2023-02-05 01:50:35'} +{'device': 'SSsebFMnz2vz0lKT', 'segment_ts': 'qXUp', 'time_q': '2023-02-17 15:12:43'} +{'device': 'oeMORvnHFqNvuqA9', 'segment_ts': 'D16L', 'time_q': '2023-02-17 12:56:55'} +{'device': 'pZGE5Q8ax0QnrKlK', 'segment_ts': '6O2l', 'time_q': '2023-02-17 06:43:06'} +{'device': 'xXUDPhByePkaTvpe', 'segment_ts': 'UqWC', 'time_q': '2023-02-05 01:26:33'} +{'device': '8zOXbhQQFeXPuMgW', 'segment_ts': 'v5s5', 'time_q': '2023-01-28 21:54:59'} +{'device': 'Kvd0ii9qinTBgkEK', 'segment_ts': 'YWRA', 'time_q': '2023-02-15 04:02:15'} +{'device': 'JoC3FaiJFH7nWQbY', 'segment_ts': 'RV1o', 'time_q': '2023-01-23 11:40:04'} +{'device': 'JZtyjzapfAhKTdEL', 'segment_ts': '6Hyt', 'time_q': '2023-02-12 23:31:41'} +{'device': 'lsE2LnvCTkfUv3Hb', 'segment_ts': 'mvNJ', 'time_q': '2023-02-20 04:17:14'} +{'device': 'ZaG5u6BctGV7Phak', 'segment_ts': 'xS0C', 'time_q': '2023-02-12 21:40:07'} +{'device': 'VqkvcCFemWmmdLIN', 'segment_ts': '1vCq', 'time_q': '2023-02-04 13:43:54'} +{'device': 'MnWYYlFI787w7ENs', 'segment_ts': 'YHny', 'time_q': '2023-02-02 04:12:38'} +{'device': '5dFd1cLHS8fjZaOz', 'segment_ts': '0JSK', 'time_q': '2023-02-14 05:41:43'} +{'device': 'G7r2BebALuPczt3b', 'segment_ts': 'nowH', 'time_q': '2023-02-19 08:55:48'} +{'device': '7V6SBGSNrMZUvrw8', 'segment_ts': 'KKuH', 'time_q': '2023-02-07 03:00:14'} +{'device': 'YWmt4ZWofrE68Eg4', 'segment_ts': '9ub1', 'time_q': '2023-01-24 10:32:07'} +{'device': 'RgsF3Paw1CFHmXrz', 'segment_ts': 'GKFG', 'time_q': '2023-02-05 14:23:12'} +{'device': 'uRUd8DnEptcCg051', 'segment_ts': 'w6bQ', 'time_q': '2023-02-12 02:55:44'} +{'device': 'gpJn2OhNJ17yFKfj', 'segment_ts': 'Ms6E', 'time_q': '2023-02-11 12:28:14'} +{'device': 'OS8p3UgcZwCtitJ5', 'segment_ts': 'lUE6', 'time_q': '2023-02-12 12:43:29'} +{'device': 'AaBf2goUzSIOLwKU', 'segment_ts': 'jRhp', 'time_q': '2023-01-28 02:43:57'} +{'device': 'Gi7o9G6zuxIje6TA', 'segment_ts': 'TPjM', 'time_q': '2023-01-22 21:42:14'} +{'device': 'Zgp8HrnLjtoUBstx', 'segment_ts': '669s', 'time_q': '2023-01-23 07:40:22'} +{'device': 'yZ39wYgza1sjjH6a', 'segment_ts': '80La', 'time_q': '2023-01-25 23:58:17'} +{'device': 'gKSePVA4eUpPeQeB', 'segment_ts': 'uPAl', 'time_q': '2023-02-06 04:22:11'} +{'device': 'ZvPnZt45ZdDJf2wV', 'segment_ts': 'eQg8', 'time_q': '2023-01-29 16:01:24'} +{'device': 'RGaReXrDxjLvIN1h', 'segment_ts': 'wV8N', 'time_q': '2023-01-27 01:38:59'} +{'device': 'DBG2BbMzd2AiJ1ra', 'segment_ts': 'or1s', 'time_q': '2023-02-14 19:21:12'} +{'device': 'LaRpvrLjCem5I1iG', 'segment_ts': 'MKyg', 'time_q': '2023-01-22 20:08:37'} +{'device': '6VPMKOpB2Gax57AM', 'segment_ts': 'jWnU', 'time_q': '2023-02-02 08:27:23'} +{'device': 'WWmDiCgEhcFaRoxd', 'segment_ts': 'IcRw', 'time_q': '2023-01-28 20:36:01'} +{'device': 'g8tKyCuvwcmnOleP', 'segment_ts': 'l57C', 'time_q': '2023-02-21 12:15:51'} +{'device': 'mGmZoqlgLWwRHhWd', 'segment_ts': 'MJWQ', 'time_q': '2023-01-26 00:54:26'} +{'device': '9vYzND4LhGIpLRPs', 'segment_ts': 'X8An', 'time_q': '2023-02-17 17:12:20'} +{'device': 'TqAci7xzsz9HKRwX', 'segment_ts': 'HQvb', 'time_q': '2023-02-07 19:26:19'} +{'device': 'jXeyesYOxpErf0Wr', 'segment_ts': '9Pah', 'time_q': '2023-01-29 07:43:44'} +{'device': 'PKpsammUcBhHIj4d', 'segment_ts': 'SJ96', 'time_q': '2023-02-01 11:22:01'} +{'device': 'd43Y87nTdkx4nw0N', 'segment_ts': 'qt7V', 'time_q': '2023-02-13 07:35:55'} +{'device': '3wSdpuLVAqb2DqwQ', 'segment_ts': '1uul', 'time_q': '2023-02-20 17:20:48'} +{'device': 'b86HMaTJskEFSegv', 'segment_ts': 'e0pl', 'time_q': '2023-02-20 04:23:59'} +{'device': 'q7XDusNiRySmmaRj', 'segment_ts': '7dBw', 'time_q': '2023-01-29 01:47:01'} +{'device': 'LrWDgsZruGK3akSe', 'segment_ts': '0vLc', 'time_q': '2023-02-20 13:19:00'} +{'device': 'JJOo2fsdKEG6QCRu', 'segment_ts': 'LN5W', 'time_q': '2023-02-12 01:36:02'} +{'device': 'iXc2nZTT1U0iWf2W', 'segment_ts': '3ftI', 'time_q': '2023-02-21 10:12:08'} +{'device': 'YJ4TjVpH6ZQhMvrH', 'segment_ts': 'IVww', 'time_q': '2023-01-24 12:14:46'} +{'device': '4cBW0bSimlW8ygs0', 'segment_ts': 'tGGE', 'time_q': '2023-02-13 11:54:22'} +{'device': 'Ye2BuE77YVbChRNA', 'segment_ts': 'SRVM', 'time_q': '2023-01-25 16:55:03'} +{'device': 'BD4sQkvrmTWcfgdd', 'segment_ts': 'uqv1', 'time_q': '2023-02-17 14:21:23'} +{'device': 'kB9K8PKJpQnkJTcd', 'segment_ts': 'WCit', 'time_q': '2023-02-20 20:54:19'} +{'device': 'uSAbl2Nyu6nK3ddO', 'segment_ts': '0cq0', 'time_q': '2023-01-28 17:04:49'} +{'device': 'uJEVeGx0jSYrxfsx', 'segment_ts': 'GL95', 'time_q': '2023-02-19 21:43:48'} +{'device': 'wowb2b399vUqVxWH', 'segment_ts': 'YcDM', 'time_q': '2023-02-03 10:03:34'} +{'device': 'Yt42EPAk8TRsKsha', 'segment_ts': '9vzm', 'time_q': '2023-02-06 16:06:01'} +{'device': 'nuQgvAgPYUF1ML4s', 'segment_ts': 'SOUQ', 'time_q': '2023-02-02 10:23:33'} +{'device': 'LEuEmNLEgjoCu3p1', 'segment_ts': 'Mhpw', 'time_q': '2023-01-31 19:35:49'} +{'device': '4H1WoLSdS2qs5jOM', 'segment_ts': 'II21', 'time_q': '2023-02-10 14:24:09'} +{'device': 'dN5oTZXijbMTz8OP', 'segment_ts': 'NOvo', 'time_q': '2023-01-27 11:27:12'} +{'device': 'i2ITUxoWBCEdW8Bs', 'segment_ts': 'FqD3', 'time_q': '2023-01-30 06:33:32'} +{'device': 'NyZi9ibptktAZTjI', 'segment_ts': 'C24z', 'time_q': '2023-02-13 18:48:37'} +{'device': '5MMCow4pOwRmSIlc', 'segment_ts': 'NuYD', 'time_q': '2023-02-03 15:50:35'} +{'device': 'lK52wLIAUCcXP4AH', 'segment_ts': 'geC5', 'time_q': '2023-02-14 07:33:08'} +{'device': 'kdEACkrL59EG8vBX', 'segment_ts': '44WL', 'time_q': '2023-02-15 16:46:30'} +{'device': 'BZhrV8EAlPBft7XX', 'segment_ts': 'w04k', 'time_q': '2023-02-16 03:47:55'} +{'device': '8mKdbrORBbygBkPb', 'segment_ts': '3x0X', 'time_q': '2023-01-27 04:58:59'} +{'device': 'C3ue47cXeXukj7rU', 'segment_ts': '7AXG', 'time_q': '2023-02-14 15:59:38'} +{'device': 'PFZtQxNxLhvhEuil', 'segment_ts': 'mCKg', 'time_q': '2023-02-12 16:29:55'} +{'device': 'Qfa7tEckTSssilkU', 'segment_ts': '3Epz', 'time_q': '2023-01-30 04:49:42'} +{'device': 'OZGXqiDoUPo7codg', 'segment_ts': 'k234', 'time_q': '2023-02-21 02:14:45'} +{'device': 'VcXbfEsURAyiOlXz', 'segment_ts': 'XXHG', 'time_q': '2023-02-06 21:09:36'} +{'device': 'd9jY3TNnU9v39DOE', 'segment_ts': 'JBAB', 'time_q': '2023-02-13 05:44:52'} +{'device': 'bY1aO1ktexSWKAjB', 'segment_ts': 'OUWG', 'time_q': '2023-02-19 16:34:05'} +{'device': '4J0KbbaKXbT17iAy', 'segment_ts': 'THLZ', 'time_q': '2023-02-19 16:01:05'} +{'device': 'TdfnSWLdZuoHDmT4', 'segment_ts': '9bQC', 'time_q': '2023-02-13 07:47:03'} +{'device': 'vKvuSLFrmEElACFv', 'segment_ts': 'WgTc', 'time_q': '2023-02-01 05:41:50'} +{'device': 'EgUuFOflBQ4zUJz2', 'segment_ts': 'dfJl', 'time_q': '2023-02-11 07:30:24'} +{'device': '3cWfkAf3Ma8T8KkO', 'segment_ts': 'PDJS', 'time_q': '2023-02-05 03:09:15'} +{'device': 'xoCum1PFgRMFFAtd', 'segment_ts': 'bdMN', 'time_q': '2023-02-10 21:10:02'} +{'device': 'G10WOxXP7vDSrqG2', 'segment_ts': '9vHF', 'time_q': '2023-01-25 10:44:21'} +{'device': 'GyDiESn1pQ7C2eOq', 'segment_ts': 'X5WH', 'time_q': '2023-02-10 05:32:32'} +{'device': 'Ihum52kryw40U2Pq', 'segment_ts': 'YQGo', 'time_q': '2023-01-29 03:27:14'} +{'device': '9DeVCz49iKTNFPyr', 'segment_ts': '2rzd', 'time_q': '2023-01-24 10:45:49'} +{'device': '7mW6uwngb7RD2lEp', 'segment_ts': '5jBK', 'time_q': '2023-02-11 22:13:48'} +{'device': 'xuW4yuuFgbdd4a6p', 'segment_ts': 'lkBB', 'time_q': '2023-01-31 18:54:23'} +{'device': '5kzp9NXHYWNPgYoh', 'segment_ts': 'fioj', 'time_q': '2023-01-26 03:08:34'} +{'device': 'gmWHoGjwiWF82jHM', 'segment_ts': 'kiO6', 'time_q': '2023-01-22 18:57:36'} +{'device': 'zFyepAAJnlCoeqEU', 'segment_ts': 'tJnv', 'time_q': '2023-02-01 00:26:55'} +{'device': 'EglsUmauQATFBwu6', 'segment_ts': 'fGsr', 'time_q': '2023-01-30 09:02:11'} +{'device': 'qUd53Kl4mymteZxS', 'segment_ts': 'TdgJ', 'time_q': '2023-01-27 05:11:33'} +{'device': 'F5zBVO0bkWwMjrQ3', 'segment_ts': 'yEsz', 'time_q': '2023-02-17 00:44:53'} +{'device': 'HDgL5w5o1AyW8KNq', 'segment_ts': 'WMDV', 'time_q': '2023-02-20 04:25:58'} +{'device': 'b080loiW7g8hJYZN', 'segment_ts': 's8vj', 'time_q': '2023-01-26 23:15:47'} +{'device': 'PLB1THGiEIKtVnuq', 'segment_ts': 'eqHY', 'time_q': '2023-02-17 07:42:59'} +{'device': 'Y90nqduLp4v38lVD', 'segment_ts': 'hZVY', 'time_q': '2023-02-15 14:26:35'} +{'device': 'fh35hFi6oIEaA5Df', 'segment_ts': 'TJ6P', 'time_q': '2023-01-28 02:34:05'} +{'device': 'RBLsLZ4eIt3nrLPH', 'segment_ts': '7WHK', 'time_q': '2023-01-29 20:05:29'} +{'device': '9Db2XAc0xDm9Mbmx', 'segment_ts': 'ls7g', 'time_q': '2023-02-18 08:15:15'} +{'device': 'M1Ih4aY0dYWKWegA', 'segment_ts': 'sgfr', 'time_q': '2023-02-04 00:43:41'} +{'device': '0YtmJi8QdEGnWaHz', 'segment_ts': '5HQX', 'time_q': '2023-01-25 06:09:08'} +{'device': 'LjuzkroRYOCdQSz5', 'segment_ts': 'dzph', 'time_q': '2023-01-24 00:27:56'} +{'device': 'K0y5JORnnCPqA3PL', 'segment_ts': '6jsI', 'time_q': '2023-02-06 10:18:08'} +{'device': '75xJYP1muHt9LVvt', 'segment_ts': '2PcN', 'time_q': '2023-01-25 23:49:07'} +{'device': 'aa15VzCz3SZrbBAl', 'segment_ts': 'FfVa', 'time_q': '2023-02-07 04:37:48'} +{'device': '65lf7rvFyN74HbTL', 'segment_ts': 'q9o4', 'time_q': '2023-02-10 16:57:52'} +{'device': 'BkATNfc6INXfprd4', 'segment_ts': 'QW7U', 'time_q': '2023-02-18 04:08:48'} +{'device': 'HSBPAi87vKtuhabY', 'segment_ts': 'Ft0J', 'time_q': '2023-01-29 04:20:36'} +{'device': 'Rb23K4sxSmDFCiK2', 'segment_ts': 'CZHg', 'time_q': '2023-02-04 22:53:44'} +{'device': 'VzfrrwW2GG8Au619', 'segment_ts': 'qmhZ', 'time_q': '2023-01-29 07:18:18'} +{'device': 'UW5oYzVVoP9VUNvi', 'segment_ts': 'FD5Q', 'time_q': '2023-02-13 03:55:02'} +{'device': '7ZqKm1mzPqTjKAK8', 'segment_ts': 'yAxf', 'time_q': '2023-02-03 08:04:47'} +{'device': 'RKs79WJe0pmc30Ji', 'segment_ts': 'iQ7P', 'time_q': '2023-02-14 20:17:09'} +{'device': 'fawEL3nd7h4bsCSA', 'segment_ts': '5JQi', 'time_q': '2023-02-09 09:47:37'} +{'device': '1cK5y0fv2oasCsEg', 'segment_ts': 'FZfm', 'time_q': '2023-01-24 23:15:26'} +{'device': 'fZlV1wQfgN0slT78', 'segment_ts': 'QjWp', 'time_q': '2023-01-23 18:30:49'} +{'device': 'ReYnQoZKQD7FhiPY', 'segment_ts': 'uTjn', 'time_q': '2023-01-25 01:24:16'} +{'device': 'NPuU31MUQXT5txEw', 'segment_ts': 'clSh', 'time_q': '2023-02-04 23:56:25'} +{'device': 'uu9ToklvVI6lAa9s', 'segment_ts': '9v3C', 'time_q': '2023-01-23 19:15:43'} +{'device': 'iVXaaRjEBBkz0hz3', 'segment_ts': 'aV1U', 'time_q': '2023-02-05 20:11:12'} +{'device': 'xM0S07A9cCsd9Yfn', 'segment_ts': 'MeDE', 'time_q': '2023-01-24 04:13:01'} +{'device': 'nQHMNXhbyFZ6UoDn', 'segment_ts': 'K4Ze', 'time_q': '2023-02-10 16:22:30'} +{'device': 'fXaNQOwz30KmlHrP', 'segment_ts': '36ap', 'time_q': '2023-02-14 12:08:13'} +{'device': 'dw2ya1E1U6tjsd7T', 'segment_ts': 'Jb8U', 'time_q': '2023-02-14 03:53:01'} +{'device': 'GZ0h5bYPi6E6ohn4', 'segment_ts': '44WL', 'time_q': '2023-01-29 13:46:23'} +{'device': 'wNZt7rqhrv3YtKuz', 'segment_ts': 'zaKC', 'time_q': '2023-01-25 03:03:32'} +{'device': 'RpROmDVcSKPVt0C8', 'segment_ts': 'lvES', 'time_q': '2023-02-17 21:12:47'} +{'device': 'jbZJ7XFo3s3aLnjJ', 'segment_ts': 'cvD6', 'time_q': '2023-02-17 14:55:37'} +{'device': '4Qw6ei7d9Ux7cTDd', 'segment_ts': 'gwio', 'time_q': '2023-02-01 08:26:39'} +{'device': 'JLYhTM9PRqiptyZD', 'segment_ts': 'QrPy', 'time_q': '2023-01-26 09:58:00'} +{'device': '6FO0vI0i8EqKQhd6', 'segment_ts': 'hH9B', 'time_q': '2023-01-31 23:43:46'} +{'device': 'iGeoTrx9INiZGRHX', 'segment_ts': 'X2bk', 'time_q': '2023-01-30 16:07:24'} +{'device': '5pRaiBzTt31JZkve', 'segment_ts': '8Auu', 'time_q': '2023-02-05 09:10:17'} +{'device': 'OvWvtocpkdNLqrny', 'segment_ts': 'Inti', 'time_q': '2023-02-12 21:28:35'} +{'device': 'bYwqcLrv6vNbGiov', 'segment_ts': 'ysSv', 'time_q': '2023-02-14 22:07:17'} +{'device': 'o9lqa5RcsnYdxzPx', 'segment_ts': 'R8bW', 'time_q': '2023-01-31 19:56:44'} +{'device': 'WmUqr1hnmvlRw6YO', 'segment_ts': '5viW', 'time_q': '2023-01-28 20:23:04'} +{'device': 'JhzC3ZigvlLK1seo', 'segment_ts': 'J5sY', 'time_q': '2023-02-12 20:59:49'} +{'device': 'evKPQwjRV6cBQvjy', 'segment_ts': 'dDZY', 'time_q': '2023-01-31 04:46:11'} +{'device': 'sLMrZiBFi2lonYwg', 'segment_ts': 'unUy', 'time_q': '2023-02-15 08:51:34'} +{'device': 'o4lT6snRzZnQa1HO', 'segment_ts': 'Z7Ft', 'time_q': '2023-02-03 21:15:32'} +{'device': 'hqZWBbZog5N1kD9V', 'segment_ts': 'WBtx', 'time_q': '2023-02-19 18:01:06'} +{'device': 'xXzLPLm0OsnDJwUz', 'segment_ts': 'K1Yr', 'time_q': '2023-01-28 23:13:12'} +{'device': 'KXSUj8l7UVFARe7n', 'segment_ts': 'BvbW', 'time_q': '2023-01-29 21:44:04'} +{'device': 'UvZA7BW1fWlt0GbE', 'segment_ts': 'ajjJ', 'time_q': '2023-01-24 03:31:50'} +{'device': 'cQGXvK61LboETbwo', 'segment_ts': 'Ey3g', 'time_q': '2023-01-23 21:46:37'} +{'device': 'CQ101gI3Mx4eORJw', 'segment_ts': 'Jb8U', 'time_q': '2023-01-28 03:33:22'} +{'device': 'ed2KkpZOCurKwUW1', 'segment_ts': 'ZWmw', 'time_q': '2023-02-15 06:18:12'} +{'device': 'cmsyEAqBqINzHOdc', 'segment_ts': 'MXoi', 'time_q': '2023-02-10 07:11:49'} +{'device': 'HrEkRR54fFMG0LDI', 'segment_ts': 'siac', 'time_q': '2023-02-07 23:36:13'} +{'device': 'wxGldUWtgrjazC1G', 'segment_ts': 'tvS0', 'time_q': '2023-02-04 05:46:44'} +{'device': 'RxPCG6v5f4sqllhf', 'segment_ts': 'Ysq9', 'time_q': '2023-02-12 12:54:14'} +{'device': 'r7xQr423rEko5eka', 'segment_ts': 'XPPE', 'time_q': '2023-02-07 03:44:00'} +{'device': 'wxuOz2ANcqk4RoaO', 'segment_ts': 'lDol', 'time_q': '2023-02-16 15:04:43'} +{'device': 'PlSBAhofMJFpB2uV', 'segment_ts': 'RFaV', 'time_q': '2023-02-11 22:02:11'} +{'device': 'hZ1tbXscywB9ibyA', 'segment_ts': 'xnZO', 'time_q': '2023-02-20 15:51:50'} +{'device': 'KbFXsiA8Q0SqfSF2', 'segment_ts': 'glBE', 'time_q': '2023-02-18 23:04:11'} +{'device': 'MRPK2r2JhCir2u2l', 'segment_ts': 'Med8', 'time_q': '2023-01-24 09:27:31'} +{'device': 'cEFmg5V2xJHPyqp5', 'segment_ts': 'Kd02', 'time_q': '2023-02-10 09:41:59'} +{'device': '1lwjNCCV5WEJzXT7', 'segment_ts': '5CQq', 'time_q': '2023-01-27 01:07:21'} +{'device': 'VvOulNjY9xQCblv7', 'segment_ts': 'C8F7', 'time_q': '2023-01-27 21:04:34'} +{'device': 'dF1H0PGvmSbpRyiI', 'segment_ts': 'eD44', 'time_q': '2023-01-31 13:38:45'} +{'device': 'NkDgwYVx0XveN5Dt', 'segment_ts': 'WxCz', 'time_q': '2023-02-21 07:16:46'} +{'device': 'LBsuQUNvWKpyd89V', 'segment_ts': 'V9Fm', 'time_q': '2023-02-10 12:25:41'} +{'device': 'n1KoKQk8oZ8lUPtV', 'segment_ts': 'J7YR', 'time_q': '2023-02-16 05:30:48'} +{'device': 'YDqHeGZquVwEjqQc', 'segment_ts': '2GHM', 'time_q': '2023-02-15 00:35:09'} +{'device': 'RgQGcEnSZcPxClfB', 'segment_ts': 'hvML', 'time_q': '2023-01-23 08:49:45'} +{'device': 'jSvUQlxGgJWX0n7M', 'segment_ts': 'HMSz', 'time_q': '2023-02-12 06:13:19'} +{'device': 'K7lIlpxjv71aoW9n', 'segment_ts': 'rkkj', 'time_q': '2023-02-02 15:11:54'} +{'device': 'tlcCO6MF2RYl0g96', 'segment_ts': '10GK', 'time_q': '2023-02-17 18:09:56'} +{'device': 'p4o8sJpApQwJOiox', 'segment_ts': 'XAUS', 'time_q': '2023-01-29 10:34:46'} +{'device': '525KZ78kEncXH9VI', 'segment_ts': 'ugYO', 'time_q': '2023-02-03 20:14:10'} +{'device': '7arB9WqfPZVvkzAs', 'segment_ts': 'Jydo', 'time_q': '2023-02-09 13:03:19'} +{'device': 'GsqKaz0OuOy0p8D5', 'segment_ts': 's3Xs', 'time_q': '2023-02-01 17:04:58'} +{'device': 'NJRTnXytfyhbSltj', 'segment_ts': 'pa4b', 'time_q': '2023-01-22 23:47:33'} +{'device': 'V6BcYDFUslTaeKz2', 'segment_ts': 'c3ip', 'time_q': '2023-01-24 12:24:16'} +{'device': 'Lali4GnxbDXiICfd', 'segment_ts': '5HQX', 'time_q': '2023-02-08 07:21:08'} +{'device': '4G67CFMQFfw5nKhH', 'segment_ts': 'HfZ3', 'time_q': '2023-01-27 13:08:26'} +{'device': 'VOU1PEANNqFpksPD', 'segment_ts': 'UCFz', 'time_q': '2023-02-02 17:55:58'} +{'device': 'NQkRwi0QBjL9OUfe', 'segment_ts': 'peAr', 'time_q': '2023-01-31 09:44:07'} +{'device': 'C1Nzu0HNqUqhiv4v', 'segment_ts': 'ido8', 'time_q': '2023-02-20 11:23:58'} +{'device': 'jc76NMsTRXg6yFT8', 'segment_ts': 'IlVL', 'time_q': '2023-02-04 08:44:26'} +{'device': 'mkPyfZXT9VoyITp1', 'segment_ts': 'AElH', 'time_q': '2023-02-01 22:49:56'} +{'device': 'aODXvK25bBgLB89w', 'segment_ts': 'UyMT', 'time_q': '2023-02-06 18:46:10'} +{'device': 'bIRJnUdmTWC4bQjs', 'segment_ts': 'q6P2', 'time_q': '2023-01-25 10:01:19'} +{'device': 'NwthNY2x1PiG4NXu', 'segment_ts': 'ziKj', 'time_q': '2023-01-26 00:26:01'} +{'device': 'Y0Jwgj0CtaaVPGLU', 'segment_ts': 'uRmO', 'time_q': '2023-02-13 01:29:07'} +{'device': 'P59OfLIdsNz1u2bf', 'segment_ts': 'hm6H', 'time_q': '2023-01-25 21:43:28'} +{'device': 'dHwliEj94uGOjy4z', 'segment_ts': 'bgF8', 'time_q': '2023-02-16 14:27:07'} +{'device': 'Tp85tKVvwtOGxCsN', 'segment_ts': 'z871', 'time_q': '2023-02-03 03:24:04'} +{'device': 'Nu5VHjVpGjotVjHh', 'segment_ts': 'u8t8', 'time_q': '2023-02-14 04:32:01'} +{'device': 'rWcINdZOiu9BHzkL', 'segment_ts': 'CVvt', 'time_q': '2023-02-07 13:15:38'} +{'device': 'yGILVrj3iinOAS4U', 'segment_ts': '0fQb', 'time_q': '2023-02-01 08:06:25'} +{'device': 'CkVe5GZWBIuoCDh9', 'segment_ts': '0JA6', 'time_q': '2023-02-14 22:41:17'} +{'device': 'gGG9uQjtROdibp0O', 'segment_ts': 'mwXi', 'time_q': '2023-02-18 08:50:46'} +{'device': 'GljeFNPy2bmdxmEz', 'segment_ts': '7Jts', 'time_q': '2023-02-06 12:45:43'} +{'device': '3xlhVhGTJmURk3MX', 'segment_ts': 'NZxR', 'time_q': '2023-02-02 14:51:14'} +{'device': '47ujFWpbmPFKdX1g', 'segment_ts': 'KNqJ', 'time_q': '2023-01-25 06:27:30'} +{'device': 'gNDkMVt00vJT84jK', 'segment_ts': 'WX3F', 'time_q': '2023-02-09 12:57:48'} +{'device': 'LCaDtdl6EqAmPlGU', 'segment_ts': 'AVAC', 'time_q': '2023-02-14 13:38:47'} +{'device': 'RMS3UOMf4mt5Nlfx', 'segment_ts': 'dDQ0', 'time_q': '2023-02-15 20:39:12'} +{'device': 'mCCyHPx2EyQkjDI6', 'segment_ts': 'mvNJ', 'time_q': '2023-02-13 15:16:22'} +{'device': 'TWoLnaxEPgoNH3Fk', 'segment_ts': 'bwdO', 'time_q': '2023-02-11 09:10:07'} +{'device': '2U0w1oZWqt42ge69', 'segment_ts': 'OQPD', 'time_q': '2023-02-08 05:38:25'} +{'device': 'Wr1pqW7ogHm1l57C', 'segment_ts': 'yEsz', 'time_q': '2023-02-19 15:25:54'} +{'device': 'X2x7ETjtNN7XU6wE', 'segment_ts': 'R4fq', 'time_q': '2023-02-09 09:30:45'} +{'device': 'JJsmrj8eGnKEpkgT', 'segment_ts': 'jHFs', 'time_q': '2023-01-28 19:05:13'} +{'device': 'jQOGpX4X5gohJjgf', 'segment_ts': 'NDT5', 'time_q': '2023-01-28 07:12:42'} +{'device': 'CktBzqEuXCvd6ThV', 'segment_ts': 'ItFE', 'time_q': '2023-01-24 21:16:41'} +{'device': 'o9JPJauPfRraIlLu', 'segment_ts': '76j0', 'time_q': '2023-01-23 20:11:55'} +{'device': 'QdHyZk5P5vaBYTak', 'segment_ts': 'mfIG', 'time_q': '2023-02-08 05:08:49'} +{'device': 'u4QrAiPlcTouwbT5', 'segment_ts': 'YZHZ', 'time_q': '2023-02-14 11:46:14'} +{'device': '65dIzY2Z9TJWgbhv', 'segment_ts': 'EqdZ', 'time_q': '2023-01-28 12:55:23'} +{'device': 'kT4R6IGOTSqzw7uB', 'segment_ts': 'SGHa', 'time_q': '2023-02-11 03:18:04'} +{'device': '66KWZA8L7G89WDZI', 'segment_ts': 'wTC5', 'time_q': '2023-02-21 14:23:50'} +{'device': 'LRxsGXs41oqHtRqM', 'segment_ts': 'u7El', 'time_q': '2023-02-09 14:03:09'} +{'device': 'hgyESiq7XGtiQCql', 'segment_ts': 'hxmr', 'time_q': '2023-01-26 12:29:40'} +{'device': '0qbdQklTFNy7ISCH', 'segment_ts': 'R9B9', 'time_q': '2023-01-29 15:23:30'} +{'device': 'xYAjqmLYwZPiLGsd', 'segment_ts': 'lIlA', 'time_q': '2023-02-17 07:43:40'} +{'device': 'BzgAUk3wTrBt2JWM', 'segment_ts': 'sfqh', 'time_q': '2023-02-16 04:38:46'} +{'device': 'UrSOAFfBipxV2iV0', 'segment_ts': 'Il3r', 'time_q': '2023-02-13 10:27:30'} +{'device': 'ALr9hJYdlrw6oNcJ', 'segment_ts': 'Keh8', 'time_q': '2023-01-23 20:17:27'} +{'device': 'GVDWDnyS3E5WQkFK', 'segment_ts': 'uW7S', 'time_q': '2023-02-11 17:04:10'} +{'device': '2OKxK3JW7y96EHEa', 'segment_ts': 'KFml', 'time_q': '2023-01-28 00:05:53'} +{'device': 'FPkKren0hQTn7grY', 'segment_ts': 'eShQ', 'time_q': '2023-02-04 04:45:29'} +{'device': 'FWyRyqknGMhkVpo3', 'segment_ts': 'ZdoH', 'time_q': '2023-02-15 23:28:49'} +{'device': 'JK21TkVFQLsvKUG0', 'segment_ts': '1MVW', 'time_q': '2023-02-06 15:20:46'} +{'device': 'cjo9bUnDXUQHlnCa', 'segment_ts': 'PT3c', 'time_q': '2023-01-25 10:30:12'} +{'device': '2a0x5y7y1dd0WSHe', 'segment_ts': 'hrIh', 'time_q': '2023-02-06 13:52:24'} +{'device': 'k0TSwJgBwwVCZLlv', 'segment_ts': 'vRB7', 'time_q': '2023-02-01 22:19:25'} +{'device': 'j5LFK6TZErFfQ1VZ', 'segment_ts': 'tTr2', 'time_q': '2023-01-30 20:49:48'} +{'device': 'JGYeTG9SlkPY6wFa', 'segment_ts': 'Z9Pu', 'time_q': '2023-02-06 20:31:31'} +{'device': 'Ymh6ayRgp1H60AFc', 'segment_ts': 'Bwf8', 'time_q': '2023-02-06 00:29:22'} +{'device': 'Td0EpJOxCHYWUbrR', 'segment_ts': 'v25d', 'time_q': '2023-01-28 05:25:00'} +{'device': 'mS6Iy8Qa2mmoqYQu', 'segment_ts': '9q3k', 'time_q': '2023-01-30 00:18:20'} +{'device': 'fc6guCFHdG8VzC3p', 'segment_ts': 'QjWp', 'time_q': '2023-02-08 11:44:52'} +{'device': 'ItkmsLuHy98vfLUQ', 'segment_ts': 'JoNb', 'time_q': '2023-02-04 16:39:25'} +{'device': 'zEKKWQ45k04JGcCV', 'segment_ts': 'Tpwm', 'time_q': '2023-02-05 19:39:55'} +{'device': 'JPsTfxDVBAtWfW8r', 'segment_ts': '6sUs', 'time_q': '2023-01-29 20:29:27'} +{'device': 'yIeSaXpU3rkCbxUr', 'segment_ts': 'yZ7s', 'time_q': '2023-02-18 01:23:16'} +{'device': 'ekMZsH5A0zvUgkOr', 'segment_ts': 'KSlf', 'time_q': '2023-01-30 07:30:21'} +{'device': '4c1W84L1nNUfHkZV', 'segment_ts': 'vvM0', 'time_q': '2023-02-01 17:47:15'} +{'device': 'RBN3tJA4BYV71FBJ', 'segment_ts': 'eQg8', 'time_q': '2023-02-21 13:02:27'} +{'device': '9DS3pYWFruFTvJZS', 'segment_ts': 'rRuc', 'time_q': '2023-01-25 06:18:46'} +{'device': 'Oge628HPmV0XJxLE', 'segment_ts': 'XDA1', 'time_q': '2023-02-20 09:45:25'} +{'device': 'qHZcNOXzeJFDOsbi', 'segment_ts': 'X3q3', 'time_q': '2023-02-03 12:14:04'} +{'device': 'Z4TwRqUaxlM4nWox', 'segment_ts': 'G8xC', 'time_q': '2023-01-25 21:21:40'} +{'device': 'cN2qypm0e5KXaM4f', 'segment_ts': 'DPPO', 'time_q': '2023-02-20 05:51:54'} +{'device': 'G1umjEcxzSJpDeVf', 'segment_ts': 'ivk4', 'time_q': '2023-02-04 14:30:20'} +{'device': 'Y4YHyYf0eIA0dQT2', 'segment_ts': 'w9bo', 'time_q': '2023-01-30 04:27:41'} +{'device': 'sybCGj8bJcuWVkMH', 'segment_ts': 'n7r6', 'time_q': '2023-02-10 08:55:38'} +{'device': 'G9qtN4oPylocAhLo', 'segment_ts': 'ygKY', 'time_q': '2023-02-11 15:58:38'} +{'device': 'dqbOQmU1nCEM1tsb', 'segment_ts': 'snFa', 'time_q': '2023-01-26 05:18:19'} +{'device': 'PvXh8nHFVEKnfyw5', 'segment_ts': 'es0t', 'time_q': '2023-02-03 04:33:00'} +{'device': '9evTiKiWziX3THWt', 'segment_ts': 'mrI5', 'time_q': '2023-02-09 12:39:43'} +{'device': '8vWA3DPg0sCubmHt', 'segment_ts': 'VyRj', 'time_q': '2023-01-30 17:09:05'} +{'device': 'JBh1VD2mJSzS93VN', 'segment_ts': 'A2E6', 'time_q': '2023-01-23 22:53:01'} +{'device': 'AVTuFDv6MFEeDkkg', 'segment_ts': 'FQxa', 'time_q': '2023-02-16 15:15:49'} +{'device': 'jEnRgZZOuDplk7CK', 'segment_ts': 'McUm', 'time_q': '2023-02-13 16:58:42'} +{'device': 'w9eyvBTQMP0TlFPg', 'segment_ts': '061H', 'time_q': '2023-02-14 07:07:22'} +{'device': 'HxBZsLSXkTOwIj7U', 'segment_ts': 'Yny1', 'time_q': '2023-02-16 18:30:09'} +{'device': 'OOp6NIdrHxTZgb1a', 'segment_ts': '3gVe', 'time_q': '2023-01-27 03:18:26'} +{'device': 'XQeEiBgEVGX3xRyy', 'segment_ts': 'iK88', 'time_q': '2023-01-31 16:16:42'} +{'device': '7XXbvAMS3NbVIuSb', 'segment_ts': 'ikv3', 'time_q': '2023-01-27 17:58:57'} +{'device': 'Z77uepdP4uNOMFEm', 'segment_ts': 'aNrW', 'time_q': '2023-01-25 19:27:06'} +{'device': 'x7Ru0sut9cCNKErD', 'segment_ts': 'fSS4', 'time_q': '2023-02-16 13:17:10'} +{'device': 'tfF7ARhQav7Vs1sW', 'segment_ts': 'yFy4', 'time_q': '2023-02-18 08:18:49'} +{'device': 'IezPnCOr2g6m2iq3', 'segment_ts': 'YOF3', 'time_q': '2023-02-09 18:31:03'} +{'device': 'VOA5cvCyvFZ7bnzk', 'segment_ts': 'Viph', 'time_q': '2023-01-24 18:36:49'} +{'device': 'p0On4aZWYDoxDWHI', 'segment_ts': 'FTU0', 'time_q': '2023-02-07 02:13:54'} +{'device': 'FSpOgwOaHynPz0zH', 'segment_ts': 'WwVR', 'time_q': '2023-02-03 21:12:09'} +{'device': 'PVSlKZkOPl5hFKDc', 'segment_ts': 'AZRz', 'time_q': '2023-02-09 05:04:38'} +{'device': 'hXJ4b5HgGPtZxZDG', 'segment_ts': 'eNW4', 'time_q': '2023-02-06 20:20:25'} +{'device': 'iyM6IB8Kyie9rXTk', 'segment_ts': 'WbDH', 'time_q': '2023-01-25 02:38:32'} +{'device': 'ZHDFyhQFjT36sYEX', 'segment_ts': 'RrPC', 'time_q': '2023-01-24 13:30:11'} +{'device': 'FAmkVIvvqiBv3J2v', 'segment_ts': 'BLc4', 'time_q': '2023-02-05 01:57:00'} +{'device': 'uUlaL9nusB5K9wah', 'segment_ts': '6NJ4', 'time_q': '2023-02-04 05:09:45'} +{'device': 'uq7LIwGy8Cs8VS8S', 'segment_ts': 'Ksz1', 'time_q': '2023-01-31 14:34:35'} +{'device': 'Sljf8wt6YxMJlQ9B', 'segment_ts': '3LOG', 'time_q': '2023-02-08 01:47:29'} +{'device': '8tnuglv62PYooaqm', 'segment_ts': 'vXhF', 'time_q': '2023-02-02 02:09:46'} +{'device': 'B00CXFzWHZ7T6vw5', 'segment_ts': '993f', 'time_q': '2023-01-28 01:31:50'} +{'device': 'FsKiFfXLePj7r3xn', 'segment_ts': 'uR2f', 'time_q': '2023-02-16 05:49:48'} +{'device': 'P2Pssg8wIUhJfJge', 'segment_ts': 'SACW', 'time_q': '2023-01-23 19:12:29'} +{'device': 'F83dj5jXAaNW08tN', 'segment_ts': 'NI7t', 'time_q': '2023-02-03 06:42:10'} +{'device': 'tz2BamJyhAvZSmKL', 'segment_ts': 'WFNu', 'time_q': '2023-02-05 21:04:43'} +{'device': 'od15jkcehIGTLhka', 'segment_ts': 'pY0b', 'time_q': '2023-02-11 09:23:34'} +{'device': 'o4J3jbqm2n2VMxAV', 'segment_ts': '4G0L', 'time_q': '2023-01-24 13:22:35'} +{'device': 'uyBW48TE0tyYNDtB', 'segment_ts': 'RhKk', 'time_q': '2023-01-25 13:14:11'} +{'device': 'ANOQhJ0WObAmU99M', 'segment_ts': 'NyJ1', 'time_q': '2023-02-10 22:25:45'} +{'device': 'vDQzeXOS56cwm5Ha', 'segment_ts': '3G8I', 'time_q': '2023-02-11 19:06:38'} +{'device': 'YqyX9Xk6Kw1DXOad', 'segment_ts': 'Qk0n', 'time_q': '2023-02-10 21:58:02'} +{'device': '9neVj3Sy1VeKQxzF', 'segment_ts': 'j592', 'time_q': '2023-01-28 02:02:51'} +{'device': 'I1750EUbKfHl2yT0', 'segment_ts': 'Zztj', 'time_q': '2023-02-06 23:04:30'} +{'device': 'cdId56I5EVFYECEn', 'segment_ts': 'Trhf', 'time_q': '2023-02-05 18:35:57'} +{'device': 'mnuDFIng7Ffw33N7', 'segment_ts': '7dQn', 'time_q': '2023-01-31 14:53:16'} +{'device': 'x6GzEx5oAis07KM2', 'segment_ts': 'XcKm', 'time_q': '2023-01-23 06:33:10'} +{'device': 'k27SrvBpgJ43XRj8', 'segment_ts': 'zKI7', 'time_q': '2023-02-14 21:54:58'} +{'device': 'lhj3vbaLb1F2K4lH', 'segment_ts': 'EQLa', 'time_q': '2023-02-18 03:17:10'} +{'device': 'TRlW7EbIXGs2Bpy8', 'segment_ts': 'iOm2', 'time_q': '2023-02-04 11:54:32'} +{'device': 'klEC6kMcr7NP6sNg', 'segment_ts': 'bRK7', 'time_q': '2023-02-19 00:37:12'} +{'device': 'TEemRDFbCJdjyNsQ', 'segment_ts': 'D16L', 'time_q': '2023-02-17 11:29:57'} +{'device': 'jptd7AJiFEAk4tSw', 'segment_ts': 'IAOL', 'time_q': '2023-01-31 08:48:08'} +{'device': 'L45DvspGDQF2fOyi', 'segment_ts': 'sALF', 'time_q': '2023-02-05 03:25:00'} +{'device': 'R2NkbrNMNldSBJUG', 'segment_ts': '609r', 'time_q': '2023-02-02 09:49:49'} +{'device': '8ZqVW4kT45fPZy5a', 'segment_ts': 'l00H', 'time_q': '2023-02-11 13:05:33'} +{'device': 'jHbO5YUIUxVvdzJA', 'segment_ts': '8dJN', 'time_q': '2023-02-17 02:03:26'} +{'device': 'ktIY7e9VGCKMjL7P', 'segment_ts': 'Mxrj', 'time_q': '2023-02-20 23:12:59'} +{'device': 'uuOZC7aaCy9sUiT5', 'segment_ts': 'EUD1', 'time_q': '2023-02-01 23:31:46'} +{'device': '3RtgCZcjgxxCmg5T', 'segment_ts': '5JQi', 'time_q': '2023-01-23 12:12:05'} +{'device': 'YnI4T3vi1Lxyt5wa', 'segment_ts': 'rXIU', 'time_q': '2023-02-12 23:58:24'} +{'device': 'ev9IcNjTEZekqALB', 'segment_ts': 'GAxJ', 'time_q': '2023-01-24 12:16:20'} +{'device': 'vp5qi7TRC8KQWk7d', 'segment_ts': 'TJ6P', 'time_q': '2023-02-07 17:28:23'} +{'device': 'bSoAX2L1JHmPXODo', 'segment_ts': 'fasF', 'time_q': '2023-02-06 15:59:59'} +{'device': '3XauXuq6ws73yQla', 'segment_ts': 'SsnB', 'time_q': '2023-01-26 16:11:14'} +{'device': 'TyYnqrqHKPeqZ82q', 'segment_ts': 'Wzwh', 'time_q': '2023-02-16 20:02:19'} +{'device': 'O8hOzOOgxw2iQiHx', 'segment_ts': 'Yj0D', 'time_q': '2023-02-14 00:19:14'} +{'device': 'u4Pxs4Cyj00rtA60', 'segment_ts': '1vCq', 'time_q': '2023-01-31 16:09:15'} +{'device': 'jo8xd3EdVQRVKZG0', 'segment_ts': 'ltBU', 'time_q': '2023-01-31 07:14:48'} +{'device': 'W06dd1sDTy0apH3Y', 'segment_ts': 'ygKY', 'time_q': '2023-02-09 21:21:10'} +{'device': 'Sh7dZSxHMgFlutjC', 'segment_ts': 'MbqF', 'time_q': '2023-02-11 23:49:25'} +{'device': 'o5CLa2P1xlbs3BYb', 'segment_ts': 'v0BW', 'time_q': '2023-02-01 11:00:06'} +{'device': '4wegF6Zxl955mSik', 'segment_ts': '281a', 'time_q': '2023-01-29 11:24:20'} +{'device': 'bx31bZeyk6v3ZATS', 'segment_ts': 'wT1j', 'time_q': '2023-02-03 22:21:54'} +{'device': 'kfBaygAngrkZHyhR', 'segment_ts': 'KFml', 'time_q': '2023-02-11 02:35:20'} +{'device': 'IENwCndPscOSssCf', 'segment_ts': 'tGZF', 'time_q': '2023-02-05 15:36:28'} +{'device': 'JU1KqBsrNFR4vOqo', 'segment_ts': 'U1XA', 'time_q': '2023-01-31 18:39:08'} +{'device': '8qqyRLZQv8IAoQgP', 'segment_ts': '1WZE', 'time_q': '2023-02-03 06:48:42'} +{'device': 'rBCNpDGLi9AodGdX', 'segment_ts': '3J3I', 'time_q': '2023-02-17 06:28:51'} +{'device': 'x1VmoWLCRvrSmkEh', 'segment_ts': 'lqnk', 'time_q': '2023-01-24 18:01:20'} +{'device': 'iL3Swp4VajwaNf3O', 'segment_ts': 'gtdx', 'time_q': '2023-01-23 11:19:34'} +{'device': 'g7iVs7QsRXDubZvV', 'segment_ts': 'Oyvx', 'time_q': '2023-01-29 11:33:47'} +{'device': '4iCnj0wRJoMFKwx4', 'segment_ts': 'XU65', 'time_q': '2023-01-26 13:56:11'} +{'device': 'WWBQzqhhgRMwMVYH', 'segment_ts': 'MwvV', 'time_q': '2023-01-26 21:09:06'} +{'device': 'ZjwDtsLC8jMJIsQ6', 'segment_ts': 'NhT6', 'time_q': '2023-02-10 05:06:17'} +{'device': 'YkI6KyY3TgyviASv', 'segment_ts': 'CZdM', 'time_q': '2023-02-04 03:49:11'} +{'device': 'kemopcvgaWvww445', 'segment_ts': '9EjB', 'time_q': '2023-01-25 18:58:42'} +{'device': 'Nfuv9QZRaTdtZ1j1', 'segment_ts': 'nyoq', 'time_q': '2023-02-08 15:39:28'} +{'device': 'IDNpRkPQqBYG8rIL', 'segment_ts': 'nrGc', 'time_q': '2023-02-19 09:20:51'} +{'device': 'woj5K9AYcOPi8wbH', 'segment_ts': 'q9o4', 'time_q': '2023-01-30 00:47:23'} +{'device': 'A3Q592GiKPtRBifW', 'segment_ts': '479s', 'time_q': '2023-02-03 13:21:56'} +{'device': 't0tSKqKvPJsSLKek', 'segment_ts': 'PzBM', 'time_q': '2023-02-09 19:16:28'} +{'device': 'xvu9RL3gVCt6YIqd', 'segment_ts': 'OE7b', 'time_q': '2023-02-10 13:47:41'} +{'device': 'WMwNdlIc5a3s0o4d', 'segment_ts': 'WFNu', 'time_q': '2023-02-10 20:06:12'} +{'device': 'kkvalugYPF7CeARB', 'segment_ts': 'xOmt', 'time_q': '2023-01-27 20:04:35'} +{'device': 'O2Pxt9eTcZ8DXb7Z', 'segment_ts': '3sv4', 'time_q': '2023-02-10 23:46:23'} +{'device': 'n67yYlHFaWmgsEIn', 'segment_ts': 'MbqF', 'time_q': '2023-01-30 20:38:08'} +{'device': '4vHRlcIj4fA6nyem', 'segment_ts': 'vroI', 'time_q': '2023-02-14 16:20:29'} +{'device': 'TMbltseSls9UOzxq', 'segment_ts': 'v5gi', 'time_q': '2023-02-20 09:03:38'} +{'device': 'Jj6eg1CNcUpAtY4b', 'segment_ts': 'xd2m', 'time_q': '2023-02-16 06:33:10'} +{'device': 'ipuU6YIHXJVKYBb5', 'segment_ts': 'LwNw', 'time_q': '2023-01-28 00:19:52'} +{'device': 't66AJJAWxgfr54og', 'segment_ts': 'q74O', 'time_q': '2023-01-30 06:53:54'} +{'device': '72tpVrLi7idQ711R', 'segment_ts': 'TuWP', 'time_q': '2023-02-19 22:09:35'} +{'device': 'Hvq7OAQ6pXafCIaP', 'segment_ts': 'OdFT', 'time_q': '2023-02-17 20:46:42'} +{'device': 'pme4dFY8cxRdM0iD', 'segment_ts': '7exz', 'time_q': '2023-02-16 00:45:20'} +{'device': 'urddNEFtldtGx3WR', 'segment_ts': 'eZiz', 'time_q': '2023-02-10 06:35:13'} +{'device': 'uZvYbARAUvBgqqiC', 'segment_ts': 'AwpA', 'time_q': '2023-02-05 08:54:00'} +{'device': 'qynlelnsdXES0L3o', 'segment_ts': 'qe17', 'time_q': '2023-02-04 03:25:06'} +{'device': 'VvuWbHbURvKgsqUF', 'segment_ts': '7Sxg', 'time_q': '2023-02-14 10:47:24'} +{'device': 'TlnhHfBk12CQiQ0K', 'segment_ts': 'QVU0', 'time_q': '2023-02-11 01:01:08'} +{'device': 'pPUdA3tMUudFfuu8', 'segment_ts': 'Ubci', 'time_q': '2023-02-20 07:54:52'} +{'device': 'zgZbzsxqUD8EYtTt', 'segment_ts': 'Oyvx', 'time_q': '2023-02-16 23:14:46'} +{'device': 'mJ4o0n4HIVfcYlOo', 'segment_ts': '1Xba', 'time_q': '2023-02-09 23:33:48'} +{'device': 'aqh9qEavdsDiY54R', 'segment_ts': 'O951', 'time_q': '2023-01-23 21:18:26'} +{'device': 'baPCRewYf20VOMzV', 'segment_ts': '7QZg', 'time_q': '2023-01-30 03:32:06'} +{'device': 'JGqBYR14WAkGBwFM', 'segment_ts': '3ES4', 'time_q': '2023-02-06 06:31:37'} +{'device': 'k5Jpfk62razi9ZgC', 'segment_ts': 'jefZ', 'time_q': '2023-02-21 06:43:37'} +{'device': 'J4R3L5UMS3DjpooS', 'segment_ts': 'J8fh', 'time_q': '2023-02-12 03:19:39'} +{'device': 'mKaEAZkAqmHVYbYx', 'segment_ts': 'NZxR', 'time_q': '2023-02-20 12:07:35'} +{'device': 'mnFNrh7YGDVK0LF0', 'segment_ts': '1yCJ', 'time_q': '2023-01-29 11:05:00'} +{'device': '15x8g2YTRH5wxg8D', 'segment_ts': 'hOB3', 'time_q': '2023-02-15 09:54:07'} +{'device': 'MDhSc461Le45qIOD', 'segment_ts': 'Oqnw', 'time_q': '2023-02-13 12:55:24'} +{'device': '2wtPLtzsT0nw72Ki', 'segment_ts': 'iC7M', 'time_q': '2023-02-13 08:02:54'} +{'device': 'EJN36J2EWxJO6d3A', 'segment_ts': 'aCKQ', 'time_q': '2023-01-26 18:11:35'} +{'device': '4Cibygd0vko8tblj', 'segment_ts': 'xF4p', 'time_q': '2023-01-27 09:25:50'} +{'device': '1EryLdrZkHz9TBM2', 'segment_ts': 'M97m', 'time_q': '2023-02-06 08:09:39'} +{'device': 'NUp95xg6x9K07uJw', 'segment_ts': 'DuKl', 'time_q': '2023-02-15 14:42:37'} +{'device': 'QTvOJ3fHPnsnFksM', 'segment_ts': 'PNnd', 'time_q': '2023-01-23 22:31:31'} \ No newline at end of file diff --git a/idk/kafka/testdata/schemas/timeQuantum.json b/idk/kafka/testdata/schemas/timeQuantum.json new file mode 100644 index 000000000..a3565666e --- /dev/null +++ b/idk/kafka/testdata/schemas/timeQuantum.json @@ -0,0 +1,26 @@ +{ + "doc": "Records for testing time quantums", + "fields": [ + { + "doc": "A device ID", + "name": "device", + "type": "string" + }, + { + "doc": "The segment the device belongs to which is related to time", + "name": "segment_ts", + "type": "string", + "quantum": "YMD" + }, + { + "doc": "The timestamp associated with segment_ts", + "name": "time_q", + "type": "bytes", + "fieldType": "recordTime", + "layout": "2006-01-02 15:04:05" + } + ], + "name": "tq_record", + "namespace": "com.featurebase.tq", + "type": "record" +} \ No newline at end of file