Support Questions

Find answers, ask questions, and share your expertise
Announcements
Welcome to the upgraded Community! Read this blog to see What’s New!

Fetch stock exchange data from Alpha vantage API using Spark Streaming

avatar
Explorer

Hi,

I want to fetch stock exchange data from Alpha vantage API using Spark Streaming.

I used below API which return data in JSON format :

https://www.alphavantage.co/query?function=TIME_SERIES_INTRADAY&symbol=TCS&interval=1min&apikey=apik...

How to fetch continuous streaming of stock exchange data using Spark Streaming Java API.

1 ACCEPTED SOLUTION

avatar

@priyal patel You may want to look at creating a custom receiver for that rest endpoint:

http://spark.apache.org/docs/latest/streaming-custom-receivers.html

Another less direct option would be to use Apache Nifi (HDF) to pull the stock exchange into Kafka. Then use Spark Kafka Streaming.

HTH

*** If you found this answer addressed your question, please take a moment to login and click the "accept" link on the answer.

View solution in original post

2 REPLIES 2

avatar

@priyal patel You may want to look at creating a custom receiver for that rest endpoint:

http://spark.apache.org/docs/latest/streaming-custom-receivers.html

Another less direct option would be to use Apache Nifi (HDF) to pull the stock exchange into Kafka. Then use Spark Kafka Streaming.

HTH

*** If you found this answer addressed your question, please take a moment to login and click the "accept" link on the answer.

avatar
Explorer

Hi, @Felix Albani

Thanks.

Labels