emitter_test.py 文件源码

def test_transmit_metrics(self, mock_time, mock_socket):

        mock_socket.side_effect = MockSocket

        mock_time.return_value = strptime("30 Nov 00", "%d %b %y")

        testconv = converter.Converter()
        json_object = json.loads(
            """{"timestamp" : "975542400", "key":123.0 }""")
        result = testconv.convert_json_to_flat(json_object, "host.run-name")

        emitter = CarbonMetricTransmitter()
        emitter.carbon_port = self.listen_port
        emitter.transmit_metrics(result, None)

        self.assertEqual("host.run-name.key 123.0 975542400\n",
                         data[1],
                         data[1])