Hi Arthur,
I sort of did. Not through any connectors though. In the end I built a script that connects to the Google API that controls the MCF reports. First, I had to get my service account key to be included on my script (in a json file format). I got some sample code from the documentation site and adjusted it to pull the data I needed. I'm including it here below (in python). I'm not an expert programmer, actually this was my first script so maybe there's a more optimized way to code it.
from apiclient.discovery import build
from oauth2client.service_account import ServiceAccountCredentials
from datetime import date, timedelta,datetime
import psycopg2
def get_service(api_name, api_version, scopes, key_file_location):
credentials = ServiceAccountCredentials.from_json_keyfile_name(
key_file_location, scopes=scopes)
# Build the service object.
service = build(api_name, api_version, credentials=credentials)
return service
def get_first_profile_id(service):
# Use the Analytics service object to get the first profile id.
# Get a list of all Google Analytics accounts for this user
accounts = service.management().accounts().list().execute()
if accounts.get('items'):
# Get the first Google Analytics account.
account = accounts.get('items')[0].get('id')
# Get a list of all the properties for the first account.
properties = service.management().webproperties().list(
accountId=account).execute()
if properties.get('items'):
# Get the first property id. In my case it was 9
property = properties.get('items')[9].get('id')
# Get a list of all views (profiles) for the first property.
profiles = service.management().profiles().list(
accountId=account,
webPropertyId=property).execute()
if profiles.get('items'):
# return the first view (profile) id.
return profiles.get('items')[0].get('id')
return None
def get_results(service, profile_id):
# Use the Analytics Service Object to query the Core Reporting API
# for the number of sessions within the past seven days.
return service.data().mcf().get(
ids='ga:' + profile_id,
#start_date='7daysAgo',
start_date='3daysAgo',
end_date='today',
metrics='mcf:firstInteractionConversions',
dimensions='mcf:conversionDate,mcf:source,mcf:sourceMedium,mcf:campaignName,mcf:adwordsAdContent,mcf:basicChannelGrouping',
sort='mcf:conversionDate',
filters='mcf:conversionGoalNumber==013',
max_results='5000').execute()
def print_results(results):
if results:
#connecting with database
connection = psycopg2.connect(database = 'DATABASE_NAME', user = 'DB_USER', password = 'XXXXXX', host = 'DB_SERVER', port = 'XXXXX')
cursor = connection.cursor()
#parsing the query
if results.get('rows', []):
for row in results.get('rows'):
conversiondate = row[0].get('primitiveValue')
conversiondate = conversiondate[0:4]+'-'+conversiondate[4:6]+'-'+conversiondate[6:8]
source_ = row[1].get('primitiveValue')
sourcemedium = row[2].get('primitiveValue')
campaign = row[3].get('primitiveValue')
adcontent = row[4].get('primitiveValue')
channel = row[5].get('primitiveValue')
conversions = row[6].get('primitiveValue')
#Query the data from my DB
cursor.execute("SELECT * from ga_mcf where conversiondate = %s AND sourcemedium = %s AND campaign = %s and adcontent = %s", (str(conversiondate),str(sourcemedium),str(campaign),str(adcontent)))
a=len(cursor.fetchall())
if a>0: #update old entries
"""
print("update")
"""
cursor.execute("UPDATE ga_mcf set conversions = %s where conversiondate = %s AND sourcemedium = %s AND campaign = %s AND adcontent = %s", (str(conversions),str(conversiondate),str(sourcemedium),str(campaign),str(adcontent)))
connection.commit()
else: #Insert new rows
"""
print("insert")
"""
cursor.execute("INSERT INTO ga_mcf (conversiondate,source,sourcemedium,campaign,adcontent,channel,conversions) VALUES (%s,%s,%s,%s,%s,%s,%s)", (conversiondate,source_,sourcemedium,campaign,adcontent,channel,conversions))
connection.commit()
connection.close()
else:
print ('No results found')
def main():
# Define the auth scopes to request.
scope = 'https://www.googleapis.com/auth/analytics.readonly'
key_file_location = '.\JSON FILE HERE'
# Authenticate and construct service.
service = get_service(
api_name='analytics',
api_version='v3',
scopes=[scope],
key_file_location=key_file_location)
profile_id = get_first_profile_id(service)
print_results(get_results(service, profile_id))
if __name__ == '__main__':
main()Here are a couple of links for reference:
https://developers.google.com/analytics/devguides/reporting/mcf/dimsmets/
https://developers.google.com/analytics/devguides/reporting/mcf/v3/
I hope this helps
