Having issues with the Streaming API Sample.py

[LordNadimi]

I have been trying to work with this and trying different ways to get to the goal but it doesn't seem to be working. Even when I only use the sample provided it doesn't work as intended. The account updates, when fexample I add funds to the account, that updates as intended. but the streaming of prices does not even show.

the below code

gives this:

D:\Python\envs\Project_Allspark\python.exe D:\Project_Allspark\streamingapi.py
INFO:root:Creating new v2 session for user 'myusername' at 'https://demo-api.ig.com/gateway/deal'
INFO:root:POST '/session', resp 200
INFO:trading_ig.stream:Starting connection with https://demo-apd.marketdatasystems.com
----------HIT CR TO UNSUBSCRIBE AND DISCONNECT FROM LIGHTSTREAMER-----------
balance: {'pos': 1, 'name': 'ACCOUNT:Whatever', 'values': {'AVAILABLE_CASH': '5161570.52'}}

#!/usr/bin/env python

-- coding:utf-8 --

"""
IG Markets Stream API sample with Python
2015 FemtoTrader
"""

import logging

from trading_ig import IGService, IGStreamService
from trading_ig.config import config
from trading_ig.lightstreamer import Subscription

A simple function acting as a Subscription listener

def handle_update(epic, fields, value):
if fields == "BID":
print("The latest bid price for " + epic + " is:", value)
elif fields == "OFFER":
print("The latest ask price for " + epic + " is:", value)

def on_prices_update(item_update):

# print("price: %s " % item_update)

print(

"{stock_name:<19}: Time {UPDATE_TIME:<8} - "

"Bid {BID:>5} - Ask {OFFER:>5}".format(

stock_name=item_update["name"], **item_update["values"]

)

)

def on_account_update(balance_update):
print("balance: %s " % balance_update)

def main():
logging.basicConfig(level=logging.INFO)
# logging.basicConfig(level=logging.DEBUG)

ig_service = IGService(
    config.username, config.password, config.api_key, config.acc_type, acc_number=config.acc_number
)

ig_stream_service = IGStreamService(ig_service)
ig_stream_service.create_session()
#ig_stream_service.create_session(version='3')

# Making a new Subscription in MERGE mode
subscription_prices = Subscription(
    mode="MERGE",

    items=["IX.D.SPTRD.FWM1.IP"], #, "IX.D.RUSSELL.FWS2.IP"],

    fields=["UPDATE_TIME", "BID", "OFFER", "CHANGE", "MARKET_STATE"],
)

# Adding the "on_price_update" function to Subscription
subscription_prices.addlistener(handle_update)

# Registering the Subscription
sub_key_prices = ig_stream_service.ls_client.subscribe(subscription_prices)

# Making an other Subscription in MERGE mode
subscription_account = Subscription(
    mode="MERGE", items=["ACCOUNT:" + config.acc_number], fields=["AVAILABLE_CASH"],
)

# Adding the "on_balance_update" function to Subscription
subscription_account.addlistener(on_account_update)


# Registering the Subscription
sub_key_account = ig_stream_service.ls_client.subscribe(subscription_account)

input(
    "{0:-^80}\n".format(
        "HIT CR TO UNSUBSCRIBE AND DISCONNECT FROM \
LIGHTSTREAMER"
    )
)

# Disconnecting
ig_stream_service.disconnect()

if name == "main":
main()
`

[LordNadimi]

I solved this myself. I don't know how to delete.

But the solution is that your sample is wrong because IG changed something on their side.

In the sample, it needs to be added "MARKET"

Like this

subscription_prices = Subscription(
mode="MERGE",
items=["MARKET:L1:CS.D.GBPUSD.CFD.IP", "MARKET:L1:CS.D.USDJPY.CFD.IP"], # sample CFD epics
items=["MARKET:IX.D.SPTRD.FWM1.IP"]