mirror of
https://github.com/kuhyx/WUT_Computer_Science.git
synced 2026-07-04 18:03:14 +02:00
Krzysztof kuhy Rudnicki
e11d703c3e
git-subtree-dir: Programming/PSD git-subtree-mainline:781bfce7b1git-subtree-split:cc1989eb7b
21 lines
733 B
Python
21 lines
733 B
Python
from pyflink.datastream import StreamExecutionEnvironment
|
|
from pyflink.datastream.connectors.kafka import FlinkKafkaConsumer
|
|
from pyflink.common.serialization import SimpleStringSchema
|
|
import json
|
|
|
|
def detect_anomalies(transaction):
|
|
transaction_data = json.loads(transaction)
|
|
# Add anomaly detection logic here
|
|
return transaction_data
|
|
|
|
env = StreamExecutionEnvironment.get_execution_environment()
|
|
kafka_consumer = FlinkKafkaConsumer(
|
|
topics='transactions',
|
|
deserialization_schema=SimpleStringSchema(),
|
|
properties={'bootstrap.servers': 'localhost:9092', 'group.id': 'anomaly_detection'}
|
|
)
|
|
|
|
data_stream = env.add_source(kafka_consumer).map(detect_anomalies)
|
|
data_stream.print()
|
|
env.execute("Anomaly Detection")
|