Visual Predictive Maintenance for Production Equipment

import { Mixpeek } from 'mixpeek';

const client = new Mixpeek({ apiKey: process.env.MIXPEEK_API_KEY });

// Configure equipment inspection data collection
await client.buckets.connect({
  collection_id: 'equipment-inspections',
  bucket_uri: 's3://maintenance/inspections/',
  extractors: [
    'image-embedding',        // Visual features
    'thermal-analysis',       // Hot spots, temperature patterns
    'wear-detection',         // Corrosion, cracks, wear patterns
    'anomaly-detection',      // Deviations from baseline
    'text-extraction'         // Gauge readings, displays
  ],
  settings: {
    equipment_id_field: 'asset_tag',
    timestamp_field: 'inspection_date',
    compare_to_baseline: true,
    track_changes_over_time: true
  }
});

// Build baseline models from historical good-condition images
async function establishBaseline(equipmentType: string) {
  const baseline = await client.models.createBaseline({
    collection_id: 'equipment-inspections',
    name: `baseline-${equipmentType}`,
    filters: {
      equipment_type: equipmentType,
      condition: 'good',
      inspection_date: { $gte: '2023-01-01' }
    },
    features: [
      'visual_appearance',
      'thermal_signature',
      'component_positions',
      'surface_condition'
    ]
  });

  return baseline;
}

// Analyze inspection for early failure indicators
async function analyzeInspection(inspectionId: string) {
  const inspection = await client.collections.get(inspectionId);

  const analysis = await client.analyze({
    document_id: inspectionId,
    baseline_id: `baseline-${inspection.equipment_type}`,
    checks: [
      'thermal_hotspots',
      'visual_anomalies',
      'wear_progression',
      'component_degradation'
    ]
  });

  return {
    equipment_id: inspection.equipment_id,
    health_score: analysis.health_score,  // 0-100
    anomalies_detected: analysis.anomalies,
    wear_rate: analysis.wear_progression,
    predicted_failure: analysis.failure_prediction,
    recommended_actions: analysis.recommendations,
    confidence: analysis.confidence
  };
}

// Set up predictive maintenance alerts
await client.alerts.create({
  collection_id: 'equipment-inspections',
  name: 'Predictive Maintenance Alert',
  conditions: [
    {
      field: 'health_score',
      operator: 'below',
      threshold: 70
    },
    {
      field: 'predicted_failure.days_until',
      operator: 'below',
      threshold: 14
    },
    {
      field: 'anomalies_detected',
      operator: 'severity_above',
      threshold: 'medium'
    }
  ],
  destinations: ['cmms', 'email', 'slack'],
  include_fields: [
    'equipment_id', 'location', 'health_score',
    'predicted_failure', 'recommended_actions',
    'inspection_images'
  ]
});