mirror of
https://github.com/osrg/gobgp.git
synced 2024-05-11 05:55:10 +00:00
documentation : BGP-SR via python grpc example
This commit is contained in:
cpmarvin
committed by
FUJITA Tomonori
FUJITA Tomonori
parent
3703becd80
commit
459bcfedf4
@ -42,6 +42,50 @@ $ gobgp g r
|
||||
*> 10.0.0.0/24 1.1.1.1 100 200 00:08:02 [{Origin: ?}]
|
||||
```
|
||||
|
||||
### Adding BGP-SR policy
|
||||
|
||||
[`tools/grpc/python/sr_policy.py`](https://github.com/osrg/gobgp/blob/master/tools/grpc/python/sr_policy.py)
|
||||
shows an example for adding a bgp-sr route.
|
||||
Let's run this script.
|
||||
|
||||
```bash
|
||||
$ PYTHONPATH=$PYTHONPATH:. python sr_policy.py
|
||||
```
|
||||
|
||||
## Result of injecting the SR policy
|
||||
|
||||
Once the sr policy is injected, gobgp will advertise it to the peers with SR Policy enabled address family. Below is the output collect
|
||||
ed from Nokia SROS router with enabled SR policy address family.
|
||||
|
||||
```log
|
||||
A:R1# show router segment-routing sr-policies all color 100
|
||||
|
||||
===============================================================================
|
||||
SR-Policies Path
|
||||
===============================================================================
|
||||
-------------------------------------------------------------------------------
|
||||
Active : Yes Owner : bgp
|
||||
Color : 100
|
||||
Head : 0.0.0.0 Endpoint Addr : 10.6.6.6
|
||||
RD : 2 Preference : 11
|
||||
BSID : 300004
|
||||
TunnelId : 917525 Age : 7
|
||||
Origin ASN : 800 Origin : 10.100.1.201
|
||||
NumReEval : 0 ReEvalReason : none
|
||||
NumActPathChange: 0 Last Change : 03/23/2022 11:05:48
|
||||
Maintenance Policy: N/A
|
||||
|
||||
Path Segment Lists:
|
||||
Segment-List : 1 Weight : 12
|
||||
S-BFD State : Down S-BFD Transitio*: 0
|
||||
Num Segments : 2 Last Change : 03/22/2022 14:09:33
|
||||
Seg 1 Label : 200002 State : resolved-up
|
||||
Seg 2 Label : 200006 State : N/A
|
||||
|
||||
===============================================================================
|
||||
* indicates that the corresponding row element may have been truncated.
|
||||
```
|
||||
|
||||
## C++
|
||||
|
||||
### Generating Interface and Binary
|
||||
|
||||
174
tools/grpc/sr_policy.py
Normal file
174
tools/grpc/sr_policy.py
Normal file
@ -0,0 +1,174 @@
|
||||
#!/usr/bin/env python
|
||||
|
||||
from __future__ import absolute_import
|
||||
from __future__ import print_function
|
||||
|
||||
import grpc
|
||||
from google.protobuf.any_pb2 import Any
|
||||
|
||||
import gobgp_pb2
|
||||
import gobgp_pb2_grpc
|
||||
import attribute_pb2
|
||||
|
||||
_TIMEOUT_SECONDS = 1000
|
||||
|
||||
|
||||
def go_bgp_subnet(color, endpoint_device, target_device, sid_list, bsid_value, nh):
|
||||
"""
|
||||
inject or delete an route with <ACME>-CIDR and <ACME>-SCRUBBING community
|
||||
NLRI
|
||||
ORIGIN
|
||||
AS_PATH
|
||||
LP
|
||||
EXTENDED COMMUNITIES
|
||||
RT
|
||||
TUNNEL ENCAP
|
||||
TLVs
|
||||
SR Policy
|
||||
SUB-TLVs
|
||||
Preference
|
||||
Binding-SID
|
||||
SEG-LIST
|
||||
WEIGHT
|
||||
SEGMENT(1..n)
|
||||
"""
|
||||
channel = grpc.insecure_channel("localhost:50051")
|
||||
stub = gobgp_pb2_grpc.GobgpApiStub(channel)
|
||||
attributes = []
|
||||
segments = []
|
||||
# bgp-sr-te safi
|
||||
family = gobgp_pb2.Family(
|
||||
afi=gobgp_pb2.Family.AFI_IP, safi=gobgp_pb2.Family.SAFI_SR_POLICY
|
||||
)
|
||||
|
||||
# sr-te policy nlri
|
||||
nlri = Any()
|
||||
nlri.Pack(
|
||||
attribute_pb2.SRPolicyNLRI(
|
||||
color=color,
|
||||
distinguisher=2,
|
||||
endpoint=bytes(map(int, endpoint_device.split("."))),
|
||||
length=96,
|
||||
)
|
||||
)
|
||||
|
||||
# next-hop
|
||||
next_hop = Any()
|
||||
next_hop.Pack(
|
||||
attribute_pb2.NextHopAttribute(
|
||||
next_hop=nh,
|
||||
)
|
||||
)
|
||||
attributes.append(next_hop)
|
||||
|
||||
# Origin
|
||||
origin = Any()
|
||||
origin.Pack(attribute_pb2.OriginAttribute(origin=0))
|
||||
attributes.append(origin)
|
||||
# Ext RT Communities
|
||||
rt = Any()
|
||||
rt.Pack(
|
||||
attribute_pb2.IPv4AddressSpecificExtended(
|
||||
address=target_device, local_admin=0, sub_type=0x02, is_transitive=False
|
||||
)
|
||||
)
|
||||
communities = Any()
|
||||
communities.Pack(
|
||||
attribute_pb2.ExtendedCommunitiesAttribute(
|
||||
communities=[rt],
|
||||
)
|
||||
)
|
||||
attributes.append(communities)
|
||||
# generic sid used for bsid
|
||||
sid = Any()
|
||||
sid.Pack(
|
||||
attribute_pb2.SRBindingSID(
|
||||
s_flag=False, i_flag=False, sid=(bsid_value).to_bytes(4, byteorder="big")
|
||||
)
|
||||
)
|
||||
# bsid
|
||||
bsid = Any()
|
||||
bsid.Pack(attribute_pb2.TunnelEncapSubTLVSRBindingSID(bsid=sid))
|
||||
|
||||
# generic segment lbl
|
||||
for n in sid_list:
|
||||
segment = Any()
|
||||
segment.Pack(
|
||||
attribute_pb2.SegmentTypeA(
|
||||
flags=attribute_pb2.SegmentFlags(s_flag=False), label=n << 12
|
||||
)
|
||||
)
|
||||
segments.append(segment)
|
||||
# segment list
|
||||
seglist = Any()
|
||||
seglist.Pack(
|
||||
attribute_pb2.TunnelEncapSubTLVSRSegmentList(
|
||||
weight=attribute_pb2.SRWeight(flags=0, weight=12),
|
||||
segments=segments,
|
||||
)
|
||||
)
|
||||
# pref
|
||||
pref = Any()
|
||||
pref.Pack(attribute_pb2.TunnelEncapSubTLVSRPreference(flags=0, preference=11))
|
||||
# path name not used for now
|
||||
cpn = Any()
|
||||
cpn.Pack(
|
||||
attribute_pb2.TunnelEncapSubTLVSRCandidatePathName(
|
||||
candidate_path_name="test-path"
|
||||
)
|
||||
)
|
||||
# priority not used for now
|
||||
pri = Any()
|
||||
pri.Pack(attribute_pb2.TunnelEncapSubTLVSRPriority(priority=10))
|
||||
tun = Any()
|
||||
|
||||
# generate tunnel
|
||||
tun.Pack(
|
||||
attribute_pb2.TunnelEncapAttribute(
|
||||
tlvs=[
|
||||
attribute_pb2.TunnelEncapTLV(
|
||||
type=15,
|
||||
tlvs=[
|
||||
pref,
|
||||
bsid,
|
||||
seglist,
|
||||
# cpn,
|
||||
# pri,
|
||||
],
|
||||
)
|
||||
]
|
||||
)
|
||||
)
|
||||
|
||||
attributes.append(tun)
|
||||
|
||||
stub.AddPath(
|
||||
gobgp_pb2.AddPathRequest(
|
||||
table_type=gobgp_pb2.GLOBAL,
|
||||
path=gobgp_pb2.Path(
|
||||
nlri=nlri,
|
||||
pattrs=attributes,
|
||||
family=family,
|
||||
best=True,
|
||||
),
|
||||
),
|
||||
_TIMEOUT_SECONDS,
|
||||
)
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
nh = "10.100.1.201" # gobgp ip
|
||||
endpoint_device = "10.6.6.6" # https://datatracker.ietf.org/doc/html/draft-ietf-idr-segment-routing-te-policy-16#section-2.3
|
||||
color = 100
|
||||
target_device = "10.1.1.1" # intended head-ends for the advertised SR Policy update
|
||||
bsid_value = 300004 # bsid
|
||||
sid_list = [200002, 200006] # label stack
|
||||
go_bgp_subnet(
|
||||
color,
|
||||
endpoint_device=endpoint_device,
|
||||
target_device=target_device,
|
||||
bsid_value=bsid_value,
|
||||
sid_list=sid_list,
|
||||
nh=nh,
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user