You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The current implementation provides only for (aliased) row attributes, but not join attributes.
For example:
class TransferMapper(RowDictMapper):
""" Format
Map Transfer row into dict for sending as Kafka message
Returns:
_type_: RowDictMapper object
"""
def __init__(self, logic_row: LogicRow = None):
""" Format
Map Transfer row into dict for sending as Kafka message
Note: declare Customer.FirstName (a join field)
Returns:
_type_: RowDictMapper object
"""
transfer = super(TransferMapper, self).__init__(
model_class=models.Transfer
, logic_row=logic_row
, alias = "transfer"
, fields = [ (logic_row.row.Account.Customer.FirstName, "First"),
(logic_row.row.Account.Customer.LastName, "Last"),
models.Transfer.FromAccountID, models.Transfer.ToAccountID,
models.Transfer.TransactionDate, models.Transfer.Amount
]
)
return transfer
The text was updated successfully, but these errors were encountered:
The current implementation provides only for (aliased) row attributes, but not join attributes.
For example:
The text was updated successfully, but these errors were encountered: