Я использую pyspark с приемником Kafka для обработки потока твитов. Один из шагов моего приложения включает вызов API Google Natural Language для получения оценки настроения за твит. Тем не менее, я в
Я хочу продолжать потреблять ответ потока. Это мой код до сих пор. Я думаю, что я не могу долго поддерживать связь. OkHttpOAuthConsumer consumer = new OkHttpOAuthConsumer("**********",
"******
**** Я пытаюсь получить информацию с временной шкалы конкретного пользователя, и я пытаюсь распечатать вывод в формате Json, но я получаю AttributeError: объект 'str' имеет нет атрибута '_json'. Я нов