Validating a DataFrame Schema

def validate(df, schema):
    for col, dtype in schema.items():
        if col in df.columns:
            assert df[col].dtype == dtype, f'{col} wrong type'
    return True

# schema = {'user_id': 'int64', 'amount': 'float64'}