How to Integrate Replit with Looker

1# Option 1: SDK reads from standard Looker env vars (set these as Replit Secrets)
2# LOOKERSDK_BASE_URL=https://yourcompany.looker.com
3# LOOKERSDK_CLIENT_ID=your_client_id
4# LOOKERSDK_CLIENT_SECRET=your_client_secret
5# LOOKERSDK_VERIFY_SSL=true
6
7# Option 2: Initialize SDK explicitly from custom secret names
8import os
9import looker_sdk
10from looker_sdk import models40 as models
11
12# Configure SDK with credentials from Replit Secrets
13sdk = looker_sdk.init40(
14    base_url=os.environ['LOOKER_BASE_URL'],
15    client_id=os.environ['LOOKER_CLIENT_ID'],
16    client_secret=os.environ['LOOKER_CLIENT_SECRET']
17)
18
19# Test connection
20me = sdk.me()
21print(f'Connected to Looker as: {me.display_name} ({me.email})')

1# looker_api.py — Looker API client for Replit (Python)
2import os
3import json
4from flask import Flask, request, jsonify
5import looker_sdk
6from looker_sdk import models40 as models
7
8# Initialize SDK from Replit Secrets
9sdk = looker_sdk.init40(
10    base_url=os.environ['LOOKER_BASE_URL'],
11    client_id=os.environ['LOOKER_CLIENT_ID'],
12    client_secret=os.environ['LOOKER_CLIENT_SECRET']
13)
14
15app = Flask(__name__)
16
17@app.route('/api/query', methods=['POST'])
18def run_query():
19    """Run an inline Looker query."""
20    body = request.get_json()
21    
22    try:
23        query = models.WriteQuery(
24            model=body['model'],         # e.g., 'ecommerce'
25            view=body['view'],           # e.g., 'orders'
26            fields=body.get('fields', []),  # e.g., ['orders.count', 'orders.created_date']
27            filters=body.get('filters', {}),  # e.g., {'orders.status': 'complete'}
28            limit=str(body.get('limit', 500))
29        )
30        
31        results = sdk.run_inline_query('json', query)
32        return jsonify(json.loads(results))
33    
34    except Exception as e:
35        return jsonify({'error': str(e)}), 500
36
37@app.route('/api/looks/<int:look_id>')
38def run_look(look_id):
39    """Fetch results of a saved Looker Look."""
40    result_format = request.args.get('format', 'json')
41    
42    try:
43        results = sdk.run_look(look_id=look_id, result_format=result_format)
44        if result_format == 'json':
45            return jsonify(json.loads(results))
46        else:
47            return results, 200, {'Content-Type': 'text/csv'}
48    except Exception as e:
49        return jsonify({'error': str(e)}), 500
50
51@app.route('/api/dashboards/<int:dashboard_id>')
52def get_dashboard_info(dashboard_id):
53    """Get dashboard metadata and element list."""
54    try:
55        dashboard = sdk.dashboard(dashboard_id=str(dashboard_id))
56        return jsonify({
57            'title': dashboard.title,
58            'description': dashboard.description,
59            'element_count': len(dashboard.dashboard_elements or [])
60        })
61    except Exception as e:
62        return jsonify({'error': str(e)}), 500
63
64if __name__ == '__main__':
65    app.run(host='0.0.0.0', port=3000)

1// looker.js — Looker API client for Replit (Node.js)
2const axios = require('axios');
3const express = require('express');
4
5const LOOKER_BASE_URL = process.env.LOOKER_BASE_URL;
6const CLIENT_ID = process.env.LOOKER_CLIENT_ID;
7const CLIENT_SECRET = process.env.LOOKER_CLIENT_SECRET;
8
9if (!LOOKER_BASE_URL || !CLIENT_ID || !CLIENT_SECRET) {
10  throw new Error('Missing Looker credentials in Replit Secrets (lock icon 🔒)');
11}
12
13// Token cache
14let accessToken = null;
15let tokenExpiry = 0;
16
17async function getLookerToken() {
18  if (accessToken && Date.now() < tokenExpiry - 30000) return accessToken;
19  
20  const response = await axios.post(`${LOOKER_BASE_URL}/api/4.0/login`, {
21    client_id: CLIENT_ID,
22    client_secret: CLIENT_SECRET
23  });
24  
25  accessToken = response.data.access_token;
26  tokenExpiry = Date.now() + (response.data.token_ttl * 1000);
27  return accessToken;
28}
29
30async function lookerRequest(method, path, data = null) {
31  const token = await getLookerToken();
32  const config = {
33    method,
34    url: `${LOOKER_BASE_URL}/api/4.0${path}`,
35    headers: {
36      Authorization: `token ${token}`,
37      'Content-Type': 'application/json'
38    }
39  };
40  if (data) config.data = data;
41  const response = await axios(config);
42  return response.data;
43}
44
45const app = express();
46app.use(express.json());
47
48// Run an inline query
49app.post('/api/query', async (req, res) => {
50  const { model, view, fields, filters, limit = 500 } = req.body;
51  try {
52    // Create query
53    const query = await lookerRequest('POST', '/queries', { model, view, fields, filters, limit });
54    // Run query
55    const results = await lookerRequest('GET', `/queries/${query.id}/run/json`);
56    res.json(results);
57  } catch (err) {
58    res.status(500).json({ error: err.response?.data || err.message });
59  }
60});
61
62// Get a Look's results
63app.get('/api/looks/:lookId', async (req, res) => {
64  try {
65    const results = await lookerRequest('GET', `/looks/${req.params.lookId}/run/json`);
66    res.json(results);
67  } catch (err) {
68    res.status(500).json({ error: err.response?.data || err.message });
69  }
70});
71
72app.listen(3000, '0.0.0.0', () => console.log('Looker Node.js server running on port 3000'));