如何为不同的采集设置不同的规则

{
  "data_sources": [
    {
      "id": "source1",
      "type": "database",
      "connection_string": "mysql://user:pass@host/dbname"
    },
    {
      "id": "source2",
      "type": "api",
      "endpoint": "https://api.example.com/data"
    }
  ]
}

{
  "rules": [
    {
      "source_id": "source1",
      "rule_type": "time_based",
      "schedule": "every 5 minutes",
      "query": "SELECT * FROM table WHERE condition"
    },
    {
      "source_id": "source2",
      "rule_type": "event_based",
      "event_type": "new_order",
      "endpoint": "/orders",
      "method": "POST"
    }
  ]
}

def apply_rules(rules):
    for rule in rules:
        if rule['rule_type'] == 'time_based':
            schedule.every(rule['schedule']).do(collect_data, rule)
        elif rule['rule_type'] == 'event_based':
            subscribe_to_event(rule['event_type'], lambda event: collect_data(rule, event))

def collect_data(rule, event=None):
    if rule['source_id'] == 'source1':
        # Execute database query
        pass
    elif rule['source_id'] == 'source2':
        # Make API call
        pass

apply_rules(rules)