|
4 | 4 | import io |
5 | 5 | import os |
6 | 6 | import logging |
| 7 | +import json |
7 | 8 | import shlex |
8 | 9 | import subprocess |
9 | 10 | import time |
@@ -200,4 +201,33 @@ def update(self, doc, annotators=None, properties=None): |
200 | 201 | parseFromDelimitedString(doc, r.content) |
201 | 202 | return doc |
202 | 203 |
|
| 204 | + def tokensregex(self, text, pattern, filter=False): |
| 205 | + return self.__regex('/tokensregex', text, pattern, filter) |
| 206 | + |
| 207 | + def semgrex(self, text, pattern, filter=False): |
| 208 | + return self.__regex('/semgrex', text, pattern, filter) |
| 209 | + |
| 210 | + def tregrex(self, text, pattern, filter=False): |
| 211 | + return self.__regex('/tregex', text, pattern, filter) |
| 212 | + |
| 213 | + def __regex(self, path, text, pattern, filter): |
| 214 | + """Send a regex-related request to the CoreNLP server. |
| 215 | + :param (str | unicode) path: the path for the regex endpoint |
| 216 | + :param text: raw text for the CoreNLPServer to apply the regex |
| 217 | + :param (str | unicode) pattern: regex pattern |
| 218 | + :param (bool) filter: option to filter sentences that contain matches, if false returns matches |
| 219 | + :return: request result |
| 220 | + """ |
| 221 | + r = requests.get( |
| 222 | + self.endpoint + path, params={ |
| 223 | + 'pattern': pattern, |
| 224 | + 'filter': filter, |
| 225 | + }, data=text) |
| 226 | + output = r.text |
| 227 | + try: |
| 228 | + output = json.loads(r.text) |
| 229 | + except: |
| 230 | + pass |
| 231 | + return output |
| 232 | + |
203 | 233 | __all__ = ["CoreNLPClient", "AnnotationException", "TimeoutException", "to_text"] |
0 commit comments