تدفقات البيانات وملكيتها وعقودها

{
  "dataset": "synthetic-shipment-events",
  "grain": "one accepted event",
  "identity": ["event_id"],
  "owner": "training-flow-owner",
  "publication": "validated-complete-batch",
  "source": "invented-fixture-only"
}

لا ينشئ السجل خدمة أو تخزيناً؛ بل يعلن الهوية وقرار النشر اللذين يجب تنفيذهما والتحقق منهما.

def accepted_batch(rows):
    ids = [row['event_id'] for row in rows]
    return bool(rows) and len(ids) == len(set(ids))

assert accepted_batch([{'event_id': 'e1'}, {'event_id': 'e2'}])
assert not accepted_batch([{'event_id': 'e1'}, {'event_id': 'e1'}])
assert not accepted_batch([])

تنجح الثنائية الصحيحة ويفشل التكرار والخلو بهذه السياسة، دون بيانات خارجية أو نظام معد.