1 
class SourcetoPort(Base):
    """"""
    __tablename__ = 'source_to_port'
    id = Column(Integer, primary_key=True)
    port_no        = Column(Integer)
    src_address    = Column(String,index=True)

    #----------------------------------------------------------------------
    def __init__(self, src_address,port_no):
        """"""
        self.src_address = src_address
        self.port_no     = port_no


  def act_like_switch (self, packet, packet_in):
    """
    Implement switch-like behavior.
    """
    # Learn the port for the source MAC
    #print "RECIEVED FROM PORT ",packet_in.in_port , "SOURCE ",packet.src
    # create a Session
    #Session = sessionmaker(bind=engine)
    #session = Session()
    self.mac_to_port[packet.src]=packet_in.in_port
    #if self.mac_to_port.get(packet.dst)!=None:
    print "count for dst",session.query(SourcetoPort).filter_by(src_address=str(packet.dst)).count(),str(packet.dst)
    #if session.query(SourcetoPort).filter_by(src_address=str(packet.dst)).count():
    if session.query(exists().where(SourcetoPort.src_address == str(packet.dst))).scalar() is not None:
           #send this packet
           print "got info from the database"
           q_res = session.query(SourcetoPort).filter_by(src_address=str(packet.dst)).first()
           self.send_packet(packet_in.buffer_id, packet_in.data,q_res.port_no, packet_in.in_port)
           #create a flow modification message
           msg = of.ofp_flow_mod()
           #set the fields to match from the incoming packet
           msg.match = of.ofp_match.from_packet(packet)
           #send the rule to the switch so that it does not query the controller again.
           msg.actions.append(of.ofp_action_output(port=q_res.port_no))
           #push the rule
           self.connection.send(msg)
    else:
           #flood this packet out as we don't know about this node.
           print "flooding the first packet"
           self.send_packet(packet_in.buffer_id, packet_in.data,
                       of.OFPP_FLOOD, packet_in.in_port)
           #self.matrix[(packet.src,packet.dst)]+=1      
           entry = SourcetoPort(src_address=str(packet.src) , port_no=packet_in.in_port)
           #add the record to the session object
           session.add(entry)
           #add the record to the session object
           session.commit()

私はこのコードを持っています。私は置き換えました

#if session.query(SourcetoPort).filter_by(src_address=str(packet.dst)).count():

と

if session.query(exists().where(SourcetoPort.src_address == str(packet.dst))).scalar() is not None:

Now I am getting the following error.


  File "/home/karthik/pox/tutorial.py", line 86, in act_like_switch
    self.send_packet(packet_in.buffer_id, packet_in.data,q_res.port_no, packet_in.in_port)
AttributeError: 'NoneType' object has no attribute 'port_no'
^CINFO:core:Going down...

上記のコードは、count クエリで動作していましたが、exists クエリで動作するようになったのはなぜですか。

4

1 に答える 1

1

francis-avilaが他の質問に対する素晴らしい回答で説明したように、にはロジックの問題がありましたexists()...scalar() is not None。True または False を返すため、常に None ではありません。昨日SQLAlchemyに存在する使い方を提案していたのは私の間違いでした。

あなたのコードは正しく、次のexists()クエリ結果を使用するロジックを変更した後に動作するはずです。

if session.query(exists().where(SourcetoPort.src_address == str(packet.dst))).scalar() is not None:

に

if session.query(exists().where(SourcetoPort.src_address == str(packet.dst))).scalar():

ここで説明されている exists()...one() を使用して例外を処理するアプローチも機能します。例外の処理は、Python で条件チェックを行うだけでなく、常により高価な操作 (より多くの CPU サイクルを使用する) であることに注意してください。アプリケーションのパフォーマンスが重要でない場合は、try/catch 例外処理を使用しても問題ありません。

于 2013-05-03T15:24:37.237 に答える