parsed_json = kstream.map (лямбда (k, v): json.loads ()), проблема с неправильным синтаксисом

Question

Ошибка ниже:

SyntaxError: недопустимая синтаксическая ошибка в этой строке кода -> parsed_json = kstream.map (lambda (k, v): json.loads ()) стрелка, указывающая(> k, a), ссылка на код: https://github.com/patilankita79/Location-based-Restaurants-Recommendation-System/blob/master/BigDataProject/Consumer.py

Answer 1

Ошибка в сигнатуре лямбда-функции.Правильно:

kstream.map(lambda k, v: json.loads(v))