python 在运行时使用参数动态创建函数

如何解决python 在运行时使用参数动态创建函数

我希望在运行时动态创建函数，但我在这方面是个菜鸟，并希望知道如何使用 python3 中的可能性来漂亮地做到这一点。我在下面添加了带有注释的代码。任何人都可以让我知道如何去做吗？ 谢谢

import json
import re
import argparse
import json
import logging
import sys
from datetime import datetime
import psycopg2
from kafka import KafkaConsumer
from signal import signal,SIGINT
from sys import exit
from psycopg2.extensions import AsIs

#open connection to postgres database
CONNECTION = "dbname =nexus user=postgres password=password host=localhost port=5432"
conn=psycopg2.connect(CONNECTION)
cursor=conn.cursor()

我在这里创建了一个字典，以便稍后动态添加新行。

#Create dictionary
#I will be adding key and values here in the future and I dont wish to create functions...i want it to be dynamic as 
#all the functions have the same code....key1,key2 and key3 have been created by my manually but it does not seem to be 
#good coding.

myKPIDict = {}
myKPIDict["key1"] = ["timestamp","source","dn","broadcastPkts","discards","multicastPkts","octetRate","octets","packetRate","rateInterval"]
myKPIDict["key2"] = ["timestamp","rateInterval"]
myKPIDict["key3"] = ["timestamp","accessVlan","adminSt","cfgAccessVlan","cfgNativeVlan"]
myKPIDict["to_be_defined_in_future1"] = ["val1","val2","val3"]
myKPIDict["to_be_defined_in_future2"] = ["val11","val23","val33","val44"]



# Function to extract json value (this will never change)
def influxJsonExtractor(key,data):
 #print("entering with " + str(key)  + " and " + str(data) )
 # data is a JSON
 found=0
 try:
    val=data["fields"][key]
    return val
 except KeyError:
    pass

这里是我定义函数的地方....重复代码

## Here is where I define my functions ....repeated code
def key1(data):
   dictsql={}
   for v in myKPIDict["key1"]:
      val=getattr(sys.modules[__name__],"influxJsonExtractor")(v,data)
      print (v + "=" + str(val))
      dictsql[v]=val
   columns = dictsql.keys()
   values = [dictsql[column] for column in columns]
   insert_statement = 'insert into key1 (%s) values %s'
   print(cursor.mogrify(insert_statement,(AsIs(','.join(columns)),tuple(values))))
   cursor.execute(cursor.mogrify(insert_statement,tuple(values))))
   conn.commit()



def key2(data):
   dictsql={}
   for v in myKPIDict["key2"]:
      val=getattr(sys.modules[__name__],data)
      print (v + "=" + str(val))
      dictsql[v]=val
   columns = dictsql.keys()
   values = [dictsql[column] for column in columns]
   insert_statement = 'insert into key2 (%s) values %s'
   print(cursor.mogrify(insert_statement,tuple(values))))
   conn.commit()


def key3(data):
   dictsql={}
   for v in myKPIDict["key3"]:
      val=getattr(sys.modules[__name__],data)
      print (v + "=" + str(val))
      dictsql[v]=val
   columns = dictsql.keys()
   values = [dictsql[column] for column in columns]
   insert_statement = 'insert into key3 (%s) values %s'
   print(cursor.mogrify(insert_statement,tuple(values))))
   conn.commit()
   

这里是我认为每次向字典“myKPIDict”添加新键和值时都重新定义函数不是很酷的地方

def to_be_defined_in_future1(data):
 print("inside to_be_defined_in_future1")
 #...
 #here i have to copy the same code that exists for otherfunctions (not cool)
 # I must be able to do this dynamically...need to contact some experts on Stackoverflow


#main code
#key="key1"
key="to_be_defined_in_future1"
if key in KPIType:
           #dynamically call the function which has the same name as my key...(this works fine)
           getattr(sys.modules[__name__],key)(data)
except KeyError:
    print("ID doesn't exist")