A vehicle-based complex event processing (CEP) engine executes on a hardware computer processor in a vehicle. The CEP engine receives a first input stream onto which vehicle information related to the vehicle is published, and applies at least one query to the first input stream. The CEP engine then assesses, based on application of the query/queries, if a vehicle-related event has occurred and, if so, the CEP engine publishes an indication of occurrence of the vehicle-related event on at least one output stream of the CEP engine. In one example, the CEP engine may receive a second input stream onto which image information is published, wherein the image information is based at least in part on data provided by at least one on-board vehicle camera.