tomas-quix/7a-produce-pandas-dataframes-directly-to-kafka-without-any-extra-serialization.py

## 7a-produce-pandas-dataframes-directly-to-kafka-without-any-extra-serialization.py
# Callback triggered for each new data frame
def on_parameter_data_handler(df: pd.DataFrame):

    # If the braking force applied is more than 50%, we mark HardBraking with True
    df["HardBraking"] = df.apply(lambda row: "True" if row.Brake > 0.5 else "False", axis=1)

    stream_producer.timeseries.publish(df)  # Send data back to the stream
	# Callback triggered for each new data frame
	def on_parameter_data_handler(df: pd.DataFrame):

	# If the braking force applied is more than 50%, we mark HardBraking with True
	df["HardBraking"] = df.apply(lambda row: "True" if row.Brake > 0.5 else "False", axis=1)

	stream_producer.timeseries.publish(df) # Send data back to the stream