hop.models

class hop.models.AvroBlob(content: str | int | float | bool | None | Dict[str, Any] | List[Any] | List[str | int | float | bool | None | Dict[str, Any] | List[Any]], schema: dict = None, single_record: bool = True)

Defines an unformatted message blob.

classmethod deserialize(data, single_record=True)

Unwrap a message produced by serialize() (the “content” value).

Returns:

An instance of the model class.

classmethod load(blob_input, single_record=True)

Create a blob message from input avro data.

Parameters:

• blob_input – The encoded Avro data or file object.

• single_record – True if input avro data only contains one record. True by default.

Returns:

The Blob.

classmethod load_file(filename, single_record=True)

Create a new message model from a file.

Parameters:

• filename – The path to a file.

• single_record – True if input avro data only contains one record. True by default.

Returns:

The message model.

class hop.models.Blob(content: bytes)

Defines an opaque message blob.

classmethod deserialize(data)

Unwrap a message produced by serialize() (the “content” value).

Returns:

An instance of the model class.

classmethod load(blob_input)

Create a blob message from input data.

Parameters:

blob_input – The unstructured message data (bytes) or file object.

Returns:

The Blob.

classmethod load_file(filename)

Create a new message model from a file.

Parameters:

filename – The path to a file.

Returns:

The message model.

class hop.models.ExternalMessage(url: str)

Defines a message which refers to data stored externally at some URL

classmethod load(input)

Create a blob message from input text.

Parameters:

blob_input – The unstructured message text or file object.

Returns:

The Blob.

class hop.models.GCNCircular(header: dict, body: str)

Defines a GCN Circular structure.

The parsed GCN circular is formatted as a dictionary with the following schema:

{‘headers’: {‘title’: …, ‘number’: …, …}, ‘body’: …}

classmethod load(email_input)

Create a new GCNCircular from an RFC 822 formatted circular.

Parameters:

email_input – A file object or string.

Returns:

The GCNCircular.

serialize()

Wrap the message with its format and content.

Returns:

A dictionary with “format” and “content” keys. The value stored under “format” is the format label. The value stored under “content” is the actual encoded data.

class hop.models.GCNTextNotice(raw: bytes, fields: dict)

A GCN Notice in the plain text format.

The original message data is stored in the raw property, and the parsed message is available via the fields property, which is a dictionary.

classmethod deserialize(data)

Unwrap a message produced by serialize() (the “content” value).

Returns:

An instance of the model class.

classmethod load(input)

Create a new message model from a file object or string. This base implementation has no functionality and should not be called.

Parameters:

input – A file object or string.

Returns:

The message model.

classmethod load_file(filename)

Create a new message model from a file.

Parameters:

filename – The path to a file.

Returns:

The message model.

class hop.models.JSONBlob(content: str | int | float | bool | None | Dict[str, Any] | List[Any])

Defines an unformatted message blob.

classmethod deserialize(data)

Unwrap a message produced by serialize() (the “content” value).

Returns:

An instance of the model class.

classmethod load(blob_input)

Create a blob message from input text.

Parameters:

blob_input – The unstructured message text or file object.

Returns:

The Blob.

class hop.models.MessageModel

An abstract message model.

classmethod deserialize(data)

Unwrap a message produced by serialize() (the “content” value).

Returns:

An instance of the model class.

abstractmethod classmethod load(input_)

Create a new message model from a file object or string. This base implementation has no functionality and should not be called.

Parameters:

input – A file object or string.

Returns:

The message model.

classmethod load_file(filename)

Create a new message model from a file.

Parameters:

filename – The path to a file.

Returns:

The message model.

serialize()

Wrap the message with its format and content, for transmission of Kafka.

Returns:

A dictionary with “format” and “content” keys. The value stored under “format” is the format label. The value stored under “content” is the actual encoded data.

class hop.models.VOEvent(ivorn: str, role: str = 'observation', version: str = '2.0', Who: dict = <factory>, What: dict = <factory>, WhereWhen: dict = <factory>, How: dict = <factory>, Why: dict = <factory>, Citations: dict = <factory>, Description: dict = <factory>, Reference: dict = <factory>)

Defines a VOEvent 2.0 structure.

Implements the schema defined by:

http://www.ivoa.net/Documents/VOEvent/20110711/

classmethod load(xml_input)

Create a new VOEvent from an XML-formatted VOEvent.

Parameters:

xml_input – A file object, string, or generator.

Returns:

The VOEvent.

classmethod load_file(filename)

Create a new VOEvent from an XML-formatted VOEvent file.

Parameters:

filename – Name of the VOEvent file.

Returns:

The VOEvent.

serialize()

Wrap the message with its format and content.

Returns:

A dictionary with “format” and “content” keys. The value stored under “format” is the format label. The value stored under “content” is the actual encoded data.