How to implement RKD JSON application with Python chapter 3: News Headline

    	
            
{
  "RetrieveHeadlineML_Request_1": {
    "HeadlineMLRequest": {
      "TimeOut": <Defines maximum time in seconds to wait for a response (optional)>,
      "MaxCount": <Defines maximum number of items to be fetched (optional)>,
      "StartTime": "<Defines the start of a time window within which news stories must fall (optional)>",
      "EndTime": "<Defines the end of a time window within which news stories must fall (optional)>",
      "Direction": "Newer",
      "Filter": [ //Complex search criteria
        {
          "FreeTextConstraint": {
            "where": "headline",
            "Value": {
              "Text": "thomson reuters"
            }
          }
        }
      ]
    }
  }
}

        
        Copy
    

    	
            
import os
import sys
import requests
import json
import getpass

        
        Copy
    

    	
            
#Send HTTP request for all services
def doSendRequest(url, requestMsg, headers):
    result = None
    try:
        ##send request
        result = requests.post(url, data=json.dumps(requestMsg), headers=headers)
        ##handle error
        if result.status_code is not 200:
            print('Request fail')
            print('response status %s'%(result.status_code))
            if result.status_code == 500: ## if username or password or appid is wrong
                print('Error: %s'%(result.json()))
                result.raise_for_status()
    except requests.exceptions.RequestException as e:
        print('Exception!!!')
        print(e)
        sys.exit(1)
return result

        
        Copy
    

    	
            
## ------------------------------------------ Main App ------------------------------------------ ##
##Get username, password and applicationid
username = raw_input('Please input username: ')
##use getpass.getpass to hide user inputted password
password = getpass.getpass(prompt='Please input password: ')
appid = raw_input('Please input appid: ')

        
        Copy
    

    	
            
## Perform authentication
def CreateAuthorization(username, password, appid):
 token = None
 return token
 
## ------------------------------------------ Main App ------------------------------------------ ##
... #code froma  previouse step
token = CreateAuthorization(username,password,appid)
print('Token = %s'%(token))

        
        Copy
    

    	
            
## Perform authentication
def CreateAuthorization(username, password, appid):
    token = None
    ##create authentication request URL, message and header
    authenMsg = {'CreateServiceToken_Request_1': { 'ApplicationID':appid, 'Username':username,'Password':password }}
    authenURL = 'https://api.rkd.refinitiv.com/api/TokenManagement/TokenManagement.svc/REST/Anonymous/TokenManagement_1/CreateServiceToken_1'
    headers = {'content-type': 'application/json;charset=utf-8'}

        
        Copy
    

    	
            
##Perform authentication
def CreateAuthorization(username, password, appid):
    ... #code froma  previouse step
    print('############### Sending Authentication request message to RKD ###############')
    authenResult = doSendRequest(authenURL, authenMsg, headers)
    if authenResult and authenResult.status_code == 200:
        print('Authen success')
        print('response status %s'%(authenResult.status_code))
        ##get Token
        token = authenResult.json()['CreateServiceToken_Response_1']['Token']
    return token

        
        Copy
    

    	
            
## Perform Quote request 
def RetrieveNewsHeadline(token, appid):
    pass
 
##------------------------------------------ Main App ------------------------------------------##
token = CreateAuthorization(username,password,appid)
print('Token = %s'%(token))
## if authentiacation success, continue subscribing Quote
if token:
    RetrieveNewsHeadline(token,appid)

        
        Copy
    

    	
            
##Perform News Headline request  
def RetrieveNewsHeadline(token, appid):
    ##construct news headline URL and header
    newsURL = 'https://api.rkd.refinitiv.com/api/News/News.svc/REST/News_1/RetrieveHeadlineML_1'
    headers = {'content-type': 'application/json;charset=utf-8' ,'X-Trkd-Auth-ApplicationID': appid, 'X-Trkd-Auth-Token' : token}

        
        Copy
    

    	
            
## Perform news headlines request
  def RetrieveNewsHeadline(token, appid): 
    ##construct a news headlines request message
    ricName = raw_input('Please input Symbol: ')
    newsRequestMsg = {
      'RetrieveHeadlineML_Request_1': {
      'HeadlineMLRequest': {
        'MaxCount': 10,
        'Filter': [{
        'MetaDataConstraint': {
          'class': 'any',
          'Value': {
          'Text': ricName
          }
        }
        }]
      }
      }
    }

        
        Copy
    

    	
            
##Perform News Headline request  
def RetrieveNewsHeadline(token, appid):
    ##construct news headline URL and header
    ...
    ##construct a news headline request message
    ...
    print('############### Sending News Headline request message to RKD ###############')
    newsResult = doSendRequest(newsURL, newsRequestMsg,headers)
    if newsResult is not None and newsResult.status_code == 200:
        print('News Headline response message: ')
        print(newsResult.json())

        
        Copy
    

    	
            
$>git clone git@github.com:Refinitiv-API-Samples/Example.TRKD.Python.HTTPJSON.git

        
        Copy
    

    	
            
$>python trkd_newsheadline.py

        
        Copy