Παρακολούθηση Προόδου Ανέβασμα με Συνδρομές

Αφού ανεβάσετε ένα αρχείο στη προ-εγγεγραμμένη διεύθυνση S3 URL, η πλατφόρμα συνεχίζει να το επεξεργάζεται ασύγχρονα.

Χρησιμοποιήστε subscribeUserFeed για να λαμβάνετε γεγονότα ανέβασμα σε πραγματικό χρόνο αντί για polling.

Για το γενικό σχήμα γεγονότος, δείτε Μορφή Γεγονότος Συνδρομής.

Ροή και Κατηγορία

Τα γεγονότα ανέβασμα παραδίδονται στο:

• subscribeUserFeed

Χρησιμοποιούν:

• category: "upload"

Ονόματα Γεγονότων

Η επεξεργασία ανάρτησης εκπέμπει μια ακολουθία γεγονότων όπως:

• uploadScanned
• uploadTypeChecked
• uploadConverting
• uploadFlattened
• uploadTagsParsed
• uploadPdfMetaExtracted
• uploadCompleted
• uploadFailed

Φόρτιση Γεγονότος Ανέβασμα

Οι φόρτισεις ανέβασμα χρησιμοποιούν αυτό το βασικό σχήμα:

{
  "version": "1.0",
  "eventId": "evt...",
  "timestamp": "2026-04-24T10:38:36.822Z",
  "level": "INFO",
  "event": "uploadCompleted",
  "category": "upload",
  "groupId": null,
  "userId": "usr...",
  "requestId": null,
  "batchId": null,
  "error": null,
  "data": {
    "id": "tmp...",
    "key": "upload/usr.../tmp....pdf",
    "code": "UPLOADOK"
  }
}

data.code διατηρεί τον χαμηλότερου επιπέδου κώδικα επεξεργασίας κατά τη μετανάστευση και συμβατότητα.

Λειτουργία Συνδρομής

subscription SubscribeUserFeed {
  subscribeUserFeed {
    userId
    data
  }
}

Παράδειγμα JavaScript

const parseEnvelope = (payload) => {
  const raw = payload?.data;
  if (!raw) return null;
  return typeof raw === 'string' ? JSON.parse(raw) : raw;
};

const handleUserFeed = ({ data }) => {
  const wrapper = data?.subscribeUserFeed;
  const event = parseEnvelope(wrapper);

  if (event?.category !== 'upload') return;

  switch (event.event) {
    case 'uploadCompleted':
      console.log('upload complete', event.data.id, event.data.key);
      break;
    case 'uploadFailed':
      console.error('upload failed', event.data.code, event.data.key);
      break;
    default:
      console.log('upload progress', event.event, event.data.code);
  }
};

Πότε να το Χρησιμοποιήσετε

Αυτό είναι πιο χρήσιμο όταν θέλετε:

• να δείξετε ένα συρτάρι προόδου ή χρονολόγιο κατάστασης ανέβασμα
• να ανιχνεύσετε αποτυχίες ασύγχρονης επικύρωσης μετά την επιτυχή PUT στο S3
• να αντιδράσετε αμέσως όταν ένα πρότυπο ή ένα ανεβασμένο περιουσιακό στοιχείο είναι έτοιμο