DEV Community

Cover image for Financial Data with Python 🤑🤑
Ankush Singh Gandhi
Ankush Singh Gandhi

Posted on • Updated on

Financial Data with Python 🤑🤑

#webdev #python #api #frontend

Image description

In the fast-paced world of finance, having access to real-time market data is crucial for making informed decisions. Global Data Feeds (GDF) provides a powerful WebSocket API that enables developers to tap into a continuous stream of financial data. In this blog, we'll explore how to use the GDF WebSocket API with Python to fetch and process real-time financial information.

Understanding Global Data Feeds WebSocket API

1. Introduction to Global Data Feeds:

  • Global Data Feeds Platform: A comprehensive platform offering financial market data from various exchanges.
  • WebSocket API: A real-time communication protocol for efficient and continuous data updates.

2. Key Features of GDF WebSocket API:

  • Real-Time Price Updates: Receive live updates on stock prices, indices, and other financial instruments.
  • Market Depth Information: Access detailed market depth information for better analysis.
  • Trade Execution Updates: Stay informed about trade executions and transactions.

Getting Started with Python and GDF WebSocket API

1. Setting Up Your GDF Account:

  • Register on GDF: Sign up for an account on the Global Data Feeds platform.
  • API Access Credentials: Obtain API access credentials (API key, secret key).

2. Installing Required Python Libraries:

  • Use pip to install necessary libraries: bash pip install websocket-client requests

3. Connecting to GDF WebSocket API:

  • Use the websocket-client library to establish a WebSocket connection.
  • Implement authentication using your GDF API key.
   import websocket

   import json


# Replace with your GDF API key

   API_KEY = "your_api_key"



def on_message(ws, message):

       data = json.loads(message)

       # Process incoming data as per your requirements

       print(data)



def on_error(ws, error):

       print(f"Error: {error}")



def on_close(ws, close_status_code, close_msg):

       print("Closed")



def on_open(ws):

       auth_payload = {"event": "auth", "apiKey": API_KEY}

       ws.send(json.dumps(auth_payload))



if name == "main":

       ws_url = "wss://api.gdf.com/ws"

       ws = websocket.WebSocketApp(ws_url, on_message=on_message, on_error=on_error, on_close=on_close)

       ws.on_open = on_open

       ws.run_forever()
Enter fullscreen mode Exit fullscreen mode




Exploring Real-Time Financial Data

1. Receiving Price Updates:

  • Subscribe to specific instruments to receive real-time price updates.
  • Extract and process price information for analysis.
   def on_open(ws):

       # Subscribe to real-time updates for AAPL and MSFT stocks

       subscribe_payload = {"event": "subscribe", "ticker": ["AAPL", "MSFT"]}

       ws.send(json.dumps(subscribe_payload))


# ...



   # Process real-time price updates

   def process_price_update(data):

       instrument = data["ticker"]

       price = data["price"]

       print(f"Price Update for {instrument}: ${price}")
Enter fullscreen mode Exit fullscreen mode



  1. Accessing Market Depth Information:

  • Subscribe to market depth updates for a specific instrument.
  • Extract and analyze market depth data for better insights.
   def on_open(ws):

       # Subscribe to market depth updates for AAPL stock

       depth_subscribe_payload = {"event": "subscribe", "ticker": ["AAPL"], "depth": 5}

       ws.send(json.dumps(depth_subscribe_payload))


# ...



   # Process market depth updates

   def process_market_depth(data):

       instrument = data["ticker"]

       bids = data["bids"]

       asks = data["asks"]

       print(f"Market Depth for {instrument} - Bids: {bids}, Asks: {asks}")
Enter fullscreen mode Exit fullscreen mode



  1. Handling Trade Execution Updates:

  • Subscribe to trade execution updates for a specific instrument.
  • Capture and process trade execution data for timely information.
   def on_open(ws):

       # Subscribe to trade execution updates for AAPL stock

       trade_subscribe_payload = {"event": "subscribe", "ticker": ["AAPL"], "trades": True}

       ws.send(json.dumps(trade_subscribe_payload))


# ...



   # Process trade execution updates

   def process_trade_execution(data):

       instrument = data["ticker"]

       price = data["price"]

       quantity = data["quantity"]

       print(f"Trade Executed for {instrument} - Price: ${price}, Quantity: {quantity}")
Enter fullscreen mode Exit fullscreen mode




Advanced Usage of Global Data Feeds WebSocket API

1. Fetching Last Quotes for Multiple Instruments:

  • Extend the WebSocket subscription to receive last quotes for multiple instruments simultaneously.
  • Parse and process the last quote data for detailed insights.
   def on_open(ws):

       # Subscribe to last quotes for AAPL, MSFT, and GOOGL stocks

       last_quote_subscribe_payload = {"event": "subscribe", "ticker": ["AAPL", "MSFT", "GOOGL"], "lastquote": True}

       ws.send(json.dumps(last_quote_subscribe_payload))


# ...



   # Process last quote updates

   def process_last_quote(data):

       instrument = data["ticker"]

       bid_price = data["bid"]

       ask_price = data["ask"]

       print(f"Last Quote for {instrument} - Bid: ${bid_price}, Ask: ${ask_price}")
Enter fullscreen mode Exit fullscreen mode



  1. Fetching Strike Prices for Options:

  • Subscribe to receive information about strike prices for options on a particular underlying instrument.
  • Analyze and utilize strike price data for option trading strategies.
   def on_open(ws):

       # Subscribe to strike prices for options on AAPL

       strike_price_subscribe_payload = {"event": "subscribe", "ticker": ["AAPL"], "strikeprices": True}

       ws.send(json.dumps(strike_price_subscribe_payload))


# ...



   # Process strike price updates

   def process_strike_price(data):

       instrument = data["ticker"]

       strike_prices = data["strikeprices"]

       print(f"Strike Prices for Options on {instrument}: {strike_prices}")
Enter fullscreen mode Exit fullscreen mode



  1. Fetching Instrument Details:

  • Retrieve detailed information about a specific financial instrument.
  • Utilize instrument details for comprehensive market analysis.
   def on_open(ws):

       # Subscribe to instrument details for AAPL

       instrument_details_subscribe_payload = {"event": "subscribe", "ticker": ["AAPL"], "instrumentdetails": True}

       ws.send(json.dumps(instrument_details_subscribe_payload))


# ...



   # Process instrument details

   def process_instrument_details(data):

       instrument = data["ticker"]

       details = data["instrumentdetails"]

       print(f"Instrument Details for {instrument}: {details}")
Enter fullscreen mode Exit fullscreen mode



  1. Fetching Last Quote Array:

  • Subscribe to receive an array of last quotes for multiple instruments.
  • Handle and process the array of last quotes for efficient data analysis.
   def on_open(ws):

       # Subscribe to last quotes array for AAPL, MSFT, and GOOGL stocks

       last_quote_array_subscribe_payload = {"event": "subscribe", "ticker": ["AAPL", "MSFT", "GOOGL"], "lastquotearray": True}

       ws.send(json.dumps(last_quote_array_subscribe_payload))


# ...



   # Process last quote array updates

   def process_last_quote_array(data):

       quotes_array = data["lastquotes"]

       for quote in quotes_array:

           instrument = quote["ticker"]

           bid_price = quote["bid"]

           ask_price = quote["ask"]

           print(f"Last Quote for {instrument} - Bid: ${bid_price}, Ask: ${ask_price}")
Enter fullscreen mode Exit fullscreen mode



  1. Fetching Expiry Dates for Options:

  • Subscribe to receive expiration dates for options on a particular underlying instrument.
  • Leverage expiration date information for options trading strategies.
   def on_open(ws):

       # Subscribe to expiration dates for options on AAPL

       expiry_dates_subscribe_payload = {"event": "subscribe", "ticker": ["AAPL"], "expirydates": True}

       ws.send(json.dumps(expiry_dates_subscribe_payload))


# ...



   # Process expiry date updates

   def process_expiry_dates(data):

       instrument = data["ticker"]

       expiry_dates = data["expirydates"]

       print(f"Expiry Dates for Options on {instrument}: {expiry_dates}")
Enter fullscreen mode Exit fullscreen mode



  1. Fetching Option Chain Data:

  • Subscribe to receive the option chain data for a specific underlying instrument.
  • Analyze the option chain for various strike prices, expirations, and Greeks.
   def on_open(ws):

       # Subscribe to option chain data for AAPL

       option_chain_subscribe_payload = {"event": "subscribe", "ticker": ["AAPL"], "optionchain": True}

       ws.send(json.dumps(option_chain_subscribe_payload))


# ...



   # Process option chain updates

   def process_option_chain(data):

       instrument = data["ticker"]

       option_chain = data["optionchain"]

       print(f"Option Chain for {instrument}: {option_chain}")
Enter fullscreen mode Exit fullscreen mode



  1. Fetching Greeks for Options:

  • Subscribe to receive Greeks (Delta, Gamma, Theta, Vega) for options on a specific underlying instrument.
  • Utilize Greeks data for risk management and option pricing strategies.



def on_open(ws):

       # Subscribe to Greeks for options on AAPL

       greeks_subscribe_payload = {"event": "subscribe", "ticker": ["AAPL"], "greeks": True}

       ws.send(json.dumps(greeks_subscribe_payload))



# ...



   # Process Greeks updates

   def process_greeks(data):

       instrument = data["ticker"]

       greeks_data = data["greeks"]

       print(f"Greeks for Options on {instrument}: {greeks_data}")
Enter fullscreen mode Exit fullscreen mode




Best Practices and Considerations

1. Error Handling and Reconnection:

  • Implement robust error handling to manage unexpected scenarios.
  • Set up reconnection mechanisms to ensure continuous data flow.

2. Data Processing and Analysis:

  • Use appropriate data structures to efficiently process and store real-time data.
  • Implement algorithms for analyzing price trends, market depth, and trade executions.

3. Throttling and Rate Limiting:

  • Adhere to GDF's API usage policies, including any rate limits imposed.
  • Implement throttling mechanisms to avoid exceeding rate limits.

Advanced Real-Time Financial Applications

Image description

1. Building an Advanced Options Trading Dashboard:

  • Utilize option chain data, strike prices, and Greeks for creating a comprehensive options trading dashboard.
  • Implement real-time updates for efficient decision-making.

2. Implementing Algorithmic Trading Strategies:

  • Leverage real-time data, last quotes, and instrument details to implement algorithmic trading strategies.
  • Integrate decision-making logic based on advanced financial data.

3. Developing a Real-Time Stock Ticker:

  • Utilize GDF WebSocket API to create a dynamic stock ticker application.
  • Display real-time price updates for selected instruments.

4. Building a Market Depth Analyzer:

  • Implement a tool to visualize and analyze market depth data.
  • Use graphical representations to enhance understanding.

❤️ SPONSER ME ON GITHUB ❤️

Image description

Conclusion

Congratulations! You've explored advanced features of the Global Data Feeds WebSocket API with Python, enabling you to build sophisticated financial applications. By incorporating last quotes, strike prices, instrument details, option chain data, and Greeks into your analysis, you can take your financial insights to the next level. Happy coding and profitable trading!

Part 2 Coming Soon.......

Top comments (0)

Read next

balrajola profile image

Top 10 Modern JavaScript Patterns for 2025

balrajOla -

stormsidali2001 profile image

feewrff

Sidali Assoul -

devmarcosanjos profile image

Client-Side Rendering (CSR)

Marcos Anjos -

zanepearton profile image

Rust + WASI: Application Monitoring

Zane -