db.py 文件源码

def register_service(self, conn, service_name):
        logger.info('registering service', service_name=service_name)
        tbl = services_table

        # add service to services table
        create_service_tx = conn.begin()
        create_service_stmt = tbl.insert().values(service_name=service_name)
        result = conn.execute(create_service_stmt)
        service_id = result.inserted_primary_key[0]
        create_service_tx.commit()

        result = Registration(
            service_name=service_name,
            service_id=service_id,
            service_status=ServiceState.DISABLED,
            service_extra={})
        logger.info('service registered', registration=result)
        return result
    # pylint: enable=no-self-use