|
1 | 1 | """USGS CLI."""
|
2 | 2 |
|
3 | 3 | import asyncio
|
4 |
| -from datetime import UTC, datetime, timedelta |
| 4 | +from datetime import timedelta |
5 | 5 |
|
6 | 6 | import click
|
7 | 7 |
|
|
16 | 16 |
|
17 | 17 | # ruff: noqa:TD002
|
18 | 18 | # ruff: noqa:TD003
|
| 19 | +# ruff: noqa: ERA001 |
19 | 20 |
|
20 | 21 |
|
21 | 22 | def check_duration(
|
@@ -204,34 +205,33 @@ def usgs_earthquake_data(
|
204 | 205 | loop.run_until_complete(backpack_dispatcher.direct_connect())
|
205 | 206 |
|
206 | 207 | click.echo("complete")
|
207 |
| - |
208 |
| - result, records = backpack_dispatcher.post() |
209 |
| - |
210 |
| - if "Error" in result: |
211 |
| - click.secho(result, fg="red") |
212 |
| - elif "Warning" in result: |
213 |
| - click.secho(result, fg="yellow") |
214 |
| - else: |
215 |
| - click.secho("Data successfully sent!", fg="green") |
216 |
| - click.echo("The following items were added to Kafka:") |
217 |
| - |
218 |
| - click.echo("------") |
219 |
| - for record in records: |
220 |
| - value = record["value"] |
221 |
| - click.echo( |
222 |
| - f"{value['id']} " |
223 |
| - f"{ |
224 |
| - datetime.fromtimestamp( |
225 |
| - value['timestamp'], tz=UTC |
226 |
| - ).strftime('%Y-%m-%d %H:%M:%S') |
227 |
| - } " |
228 |
| - f"({value['latitude']},{value['longitude']}) " |
229 |
| - f"{value['depth']} km " |
230 |
| - f"M{value['magnitude']}" |
231 |
| - ) |
232 |
| - click.echo("------") |
233 |
| - |
234 |
| - click.echo( |
235 |
| - "All entries missing from this list " |
236 |
| - "have been identified as already present in Kafka." |
237 |
| - ) |
| 208 | + # result, records = backpack_dispatcher.post() |
| 209 | + # |
| 210 | + # if "Error" in result: |
| 211 | + # click.secho(result, fg="red") |
| 212 | + # elif "Warning" in result: |
| 213 | + # click.secho(result, fg="yellow") |
| 214 | + # else: |
| 215 | + # click.secho("Data successfully sent!", fg="green") |
| 216 | + # click.echo("The following items were added to Kafka:") |
| 217 | + # |
| 218 | + # click.echo("------") |
| 219 | + # for record in records: |
| 220 | + # value = record["value"] |
| 221 | + # click.echo( |
| 222 | + # f"{value['id']} " |
| 223 | + # f"{ |
| 224 | + # datetime.fromtimestamp( |
| 225 | + # value['timestamp'], tz=UTC |
| 226 | + # ).strftime('%Y-%m-%d %H:%M:%S') |
| 227 | + # } " |
| 228 | + # f"({value['latitude']},{value['longitude']}) " |
| 229 | + # f"{value['depth']} km " |
| 230 | + # f"M{value['magnitude']}" |
| 231 | + # ) |
| 232 | + # click.echo("------") |
| 233 | + # |
| 234 | + # click.echo( |
| 235 | + # "All entries missing from this list " |
| 236 | + # "have been identified as already present in Kafka." |
| 237 | + # ) |
0 commit comments