Fitbitデータ用スパークストリーミング

Question

私はFitbit Oauth 2.0を使ってフィットビットデータにアクセスしています。私はこのデータをSQLデータベースに保存しています。その後、Spark SQLを使用してデータを分析しています。 Spark Streamingを使用する必要がある場合は、OAuthの実行後にSparkにデータを取り込む方法を教えてください。

Answer 1

あなたが構造化されたデータにfitbitデータをフォーマットして、HDFS /カフカ/ソケットにそれをダンプし、対応するHDFS /カフカ/ソケット受信機を起動することができ、それを

1. を行うには、複数の方法があります。

2. 独自のカスタム受信機を作成して、OAuthまたはSQLデータベースから直接データを受信できます。