diff --git a/logstash/formatter.py b/logstash/formatter.py index 246139b..9cd18ed 100644 --- a/logstash/formatter.py +++ b/logstash/formatter.py @@ -80,9 +80,9 @@ def format_exception(cls, exc_info): @classmethod def serialize(cls, message): if sys.version_info < (3, 0): - return json.dumps(message) + return json.dumps(message, ensure_ascii=False) else: - return bytes(json.dumps(message), 'utf-8') + return bytes(json.dumps(message, ensure_ascii=False), 'utf-8') class LogstashFormatterVersion0(LogstashFormatterBase): version = 0