@juniper-tech/core
v0.1.12
Published
Common utilities for Juniper Tech models, events and actions.
Downloads
4
Readme
@juniper-tech/core
Usage
... work in progress
Kafka Topic Consumption
We use kafkajs in the core library to generate and process messages in topics.
import { JuniperKafka, JuniperConsumer } from '@juniper-tech/core'
const kafka = JuniperKafka(process.env.KAFKA_BROKERS || '', 'juniper-ingest-client', 2)
const consumer = await JuniperConsumer(kafka, 'nodejs-dev', null)
Sensor Model Interaction
We use sequelize to interact with tables and have conveniently abstracted out the model creation so you can import into your own package.
// Sequelize connection is the sequelize instance of your db
import SequelizeConnection from '../sequelize-connection'
import { SensorModel } from '@juniper-tech/core'
let sensorPg = SensorModel(DB)
// this is now a standard sequelize model and can be used like one
sensorPg.bulkCreate(data as any).catch((err:any) => {
console.error('error', err)
})